说明
当一个 Flink 程序被执行的时候,它会被映射为 Streaming Dataflow
Dataflow 由 operator 组成,operator 分为:
- Source
- Transformation
- Sink
如下图:
作用
source
数据来源,如:读取文件、从kafka获取数据等
Transformation
数据转换,如:flatMap 拆分字符串、KeyBy 分组、聚合 等
sink
把处理后的数据输出到外部系统中,如:打印到控制台、写入到文件中、保存到 ES、Hbase

