flink1.12.x Transformation-reduce自定义聚合
flink1.12.x Transformation-keyBy求最大值(maxBy方法)
flink1.12.x Transformation-keyBy求最大值(max方法)
flink1.12.x Transformation-keyBy算子
flink1.12.x Transformation-flatMap算子
flink1.12.x Transformation-filter算子
flink1.12.x Transformation-map算子
flink1.12.x 支持的数据类型
flink1.12.x 自定义source数据源-SourceFunction、ParallelSourceFunction、RichParallelSourceFunction
flink1.12.x source数据源-kafka