Replace scheduler

[NKcqx]

Sync to the newest internal code. Module compile state: src/main

• [x] streaming-api
• [x] streaming-state
• [x] streaming-runtime
• [x] streaming-common

src/test

• [x] streaming-api
• [x] streaming-state
• [x] streaming-runtime
• [x] streaming-common

Module UT:

• [x] streaming-api: 100%
• [x] streaming-state: 100%
• [ ] streaming-runtime: 70%
• [x] streaming-common: 100%