创建Stream抽象类及抽象方法buildStream，用于构建StreamGraph。我们实现了默认的Stream，buildStream方法读取Source配置生成DataStream，通过Operator配置列表按顺序生成拓扑图，通过Sink配置生成数据写出组件。
相关文章推荐
- 日均百亿级日志处理：微博基于Flink的实时计算平台建设
- 日均20万亿次计算量！腾讯基于Flink的实时流计算平台演进之路丨附PPT下载
- Oceanus:基于Apache Flink的一站式实时计算平台
- GIS+=地理信息+行业+大数据——基于云环境流处理平台下的实时交通创新型app
- GIS+=地理信息+行业+大数据——基于云环境流处理平台下的实时交通创新型app
- 【无中生有】---17---基于大数据平台的计算开发模式
- 分布式实时日志处理平台ELK
- 开放实时数据处理平台 Twitter Storm
- 基于ArcGIS10.0和Oracle10g的空间数据管理平台七（C#开发）-日志操作类
- 分布式实时日志处理平台ELK
- 李锐_hbase上搭建广告实时数据处理平台
- 日志和实时流计算处理
- 基于ArcGIS10.0和Oracle10g的空间数据管理平台七（C#开发）-日志操作类
- 基于 ELK Stack 和 Spark Streaming 的日志处理平台设计与实现
- 日志和实时流计算处理
- 大数据实时处理：百分点实时计算架构和算法
- Flink视频教程|基于Flink流处理的动态实时电商实时分析系统
- 开放实时数据处理平台 Twitter Storm(转)
- 基于ArcGIS10.0和Oracle10g的空间数据管理平台十二（C#开发）-日志管理