flink 转换算子

Transform 转换算子 1 map 2 flatMap

 

 3 Filter

 4 KeyBy

 5 滚动聚合算子（Rolling Aggregation）

这些算子可以针对 KeyedStream 的每一个支流做聚合

⚫ sum() ⚫ min() ⚫ max() ⚫ minBy() ⚫ maxBy()

 6 Reduce

 7 Split 和 Select

Split

 

Select

 

 8 Connect 和 CoMap

 

 

 9 Union

 Connect 与 Union 区别：

1 ． Union 之前两个流的类型必须是一样， Connect 可以不一样，在之后的 coMap 中再去调整成为一样的。 2. Connect 只能操作两个流， Union 可以操作多个。