Flink中的的Transformation算子及實例

Mapjava DataStream → DataStream：輸入一個參數產生一個參數。apache val env = StreamExecutionEnvironment.getExecutionEnvironment val stream = env.generateSequence(1,10) val streamMap = stream.map { x => x * 2 } stre

>>阅读原文<<