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

第一种场景

01 示例

编写Flink程序，接收socket的单词数据，并以逗号进行单词拆分打印。

spark,2

spark,5

hadoop,7

hadoop,3

02 步骤

获取 ExecutionEnvironment 运行环境

使用 socketTextStream 构建数据源

使用 keyBy 按照单词进行分组

使用 maxBy、minBy对每个分组进行操作

打印测试

03 参考代码

第二种场景

01 示例

编写Flink程序，接收socket的单词数据，并以逗号进行单词拆分打印。

辽宁,沈阳,1000

北京,朝阳,8000

辽宁,朝阳,1000

辽宁,朝阳,1000

辽宁,沈阳,2000

北京,朝阳,1000

辽宁,大连,3000

辽宁,铁岭,500

02 步骤

获取 ExecutionEnvironment 运行环境

使用 socketTextStream 构建数据源

使用 keyBy 按照单词进行分组

使用 maxBy、minBy对每个分组进行操作

打印测试

03 参考代码