启动流程完成
模仿Strom定义了数据流处理相关接口。