您的位置:首页 > 大数据

日均百亿级日志处理:微博基于Flink的实时计算平台建设 - 大数据

ceshicool 2019-10-23 18:00 826 查看

创建Stream抽象类及抽象方法buildStream,用于构建StreamGraph。我们实现了默认的Stream,buildStream方法读取Source配置生成DataStream,通过Operator配置列表按顺序生成拓扑图,通过Sink配置生成数据写出组件。

标签: