DataStream API

转换操作

flink实战–DataSteam API终极总结

Single-DataStream 操作

map

flatMap

filter

keyBy [DataStream -> KeyedStream]

reduce [KeyedStream -> DataStream]

aggregations [KeyedStream -> DataStream]

• sum

• min

• minBy

• max

• maxBy

Multi-DataStream 操作

union [DataStream -> DataStream]

connect, coMap, coFlatMap [DataStream -> DataStream]

split [DataStream -> SplitStream]

select [SplitStream -> DataStream]

iterate [DataStream -> IterativeStream -> DataStream]

物理分区操作

随机分区（Random Partitioning）：[DataStream -> DataStream]

Roundrobin Partitioning