Flink Operators 实战

本文将介绍常见的Operator使用方法，没有深奥的理论，没有复杂的分析，全部都是demo，demo，demo... 用代码来诠释每个算子也许是最佳的实战。

本内容将分为3个部分，涉及如下算子：

• 基础篇；
  • Map
  • FlatMap
  • Filter
  • KeyBy
  • Reduce
  • Aggregations
• 进阶篇；
  • Union
  • Connect&CoFlatMap
  • Iterate
• 高级篇；
  • Window Join
  • Window CoGroup
  • Window Interval Join

注意：全部代码基于flink 1.9.0