硬核！聊一聊Flink流计算常用算子
因为Transform算子基于Source算子操作，所以首先构建Flink执行环境及Source算子，后续Transform算子操作基于此： valenv=ExecutionEnvironment.getExecutionEnvironment valtextDataSet:DataSet[String]=env.fromCollection( List( 张三,1 , 李四,2 , 王五,3
因为Transform算子基于Source算子操作，所以首先构建Flink执行环境及Source算子，后续Transform算子操作基于此： valenv=ExecutionEnvironment.getExecutionEnvironment valtextDataSet:DataSet[String]=env.fromCollection( List( 张三,1 , 李四,2 , 王五,3