Flink中的的Transformation算子及实例

Mapjava DataStream → DataStream：输入一个参数产生一个参数。apache val env = StreamExecutionEnvironment.getExecutionEnvironment val stream = env.generateSequence(1,10) val streamMap = stream.map { x => x * 2 } stre

>>阅读原文<<