flink常用算子介绍

Flink中的算子是将一个或多个DataStream转换为新的DataStream，可以将多个转换组合成复杂的数据流拓扑。 在Flink中，有多种不同的DataStream类型，他们之间是使用各种算子进行的。如下图所示：   flink中常用的算子 map DataStream --> DataStream：输入一个参数产生一个参数，map的功能是对输入的参数进行转换操作。 flatMap Dat

>>阅读原文<<