Flink : Scala 1.14-SNAPSHOT API

map

mapPartition

mapPartitionWith

mapWith

max

DataSet GroupedDataSet

maxBy

DataSet GroupedDataSet

metrics

min

DataSet GroupedDataSet

minBy

DataSet GroupedDataSet

minResources