1、DataStream Transformations #

Map #

DataStream → DataStream #

FlatMap #

DataStream → DataStream #

Filter #

DataStream → DataStream #

KeyBy #

DataStream → KeyedStream #

Reduce #

KeyedStream → DataStream #

Window #

KeyedStream → WindowedStream #

WindowAll #

DataStream → AllWindowedStream #

Window Apply #

WindowedStream → DataStream #

AllWindowedStream → DataStream #

WindowReduce #

WindowedStream → DataStream #

Union #

DataStream* → DataStream #

Window Join #

DataStream,DataStream → DataStream #

Interval Join #

KeyedStream,KeyedStream → DataStream #

Window CoGroup #

DataStream,DataStream → DataStream #

Connect #

DataStream,DataStream → ConnectedStream #

CoMap, CoFlatMap #

ConnectedStream → DataStream #

Iterate #

DataStream → IterativeStream → ConnectedStream #

2、Physical Partitioning #

Custom Partitioning #

DataStream → DataStream #

Random Partitioning #

DataStream → DataStream #

Rescaling #

DataStream → DataStream #

Broadcasting #

DataStream → DataStream #

参考：

nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/operators/overview/