獲取指定字段的最大值、最小值

第一種場景

01?示例

編寫Flink程序，接收socket的單詞數(shù)據(jù)，并以逗號進(jìn)行單詞拆分打印。

spark,2

spark,5

hadoop,7

hadoop,3

02?步驟

獲取 ExecutionEnvironment 運行環(huán)境

使用 socketTextStream 構(gòu)建數(shù)據(jù)源

使用 keyBy 按照單詞進(jìn)行分組

使用 maxBy、minBy對每個分組進(jìn)行操作

打印測試

03?參考代碼

第二種場景

01?示例

編寫Flink程序，接收socket的單詞數(shù)據(jù)，并以逗號進(jìn)行單詞拆分打印。

遼寧,沈陽,1000

北京,朝陽,8000

遼寧,朝陽,1000

遼寧,朝陽,1000

遼寧,沈陽,2000

北京,朝陽,1000

遼寧,大連,3000

遼寧,鐵嶺,500

02?步驟

獲取 ExecutionEnvironment 運行環(huán)境

使用 socketTextStream 構(gòu)建數(shù)據(jù)源

使用 keyBy 按照單詞進(jìn)行分組

使用 maxBy、minBy對每個分組進(jìn)行操作

打印測試

03?參考代碼