前面我们介绍了Flink DataStream数据处理流程中的source和sink，这篇文章我们介绍一下 Flink的Transformation 的操作，一般常用的算子有下面几种，我们分别用代码来演示下他基本用法： Map操作 val stream = env.generateSequence(1, 5) //简单的map操作 //val streamMap = stream.map(item => item * 3) //复杂的map操作 val streamMap = stre...