Flink 1.7.2 dataset transformation 示例
Flink 1.7.2 dataset transformation 示例 源码 https://github.com/opensourceteams/flink-maven-scala 概述 Flink transformation示例 map,flatMap,filter,reduce,groupBy,reduceGroup,combineGroup,Aggregate(sum,max,min) distinct,join,join funtion,leftOuterJoin,rightOuterJoin,fullOuterJoin,union,first,coGroup,cross transformation map 对集合元素,进行一一遍历处理 示例功能:给集合中的每一一行,都拼接字符串 package com.opensourceteams.module.bigdata.flink.example.dataset.transformation.map import org.apache.flink.api.scala.ExecutionEnvironment import ...