flink1.12.x Streaming Dataflow:source、Transformation、sink和对应程序代码

说明

当一个 Flink 程序被执行的时候,它会被映射为 Streaming Dataflow

Dataflow 由 operator 组成,operator 分为:

  • Source
  • Transformation
  • Sink

如下图:

作用

source

数据来源,如:读取文件、从kafka获取数据等

Transformation

数据转换,如:flatMap 拆分字符串、KeyBy 分组、聚合 等

sink

把处理后的数据输出到外部系统中,如:打印到控制台、写入到文件中、保存到 ES、Hbase

对应程序代码


原文出处:/show_1IX1zUWFcAGQ.html