Flink DataStream经常使用算子

Flink中的算子是将一个或多个DataStream转换为新的DataStream，能够将多个转换组合成复杂的数据流拓扑。html 在Flink中，有多种不一样的DataStream类型，他们之间是使用各类算子进行的。以下图所示： java 如下列举下经常使用的算子，用到的代码例子都是Flink监听9000端口作为数据源。如下方法能够启动一个9000的socket端口服务。web Linux平台上

>>阅读原文<<