按照指定的key来对流中的数据进行分组，前面入门案例中已经演示过

注意: 

流处理中没有groupBy，而是keyBy

函数说明

KeySelector对象可以支持元组类型，也可以支持POJO

元组类型

• 单个字段keyBy

• 多个字段keyBy

上述可用lambda简化

POJO

• 单个字段keyBy

• 多个字段keyBy

上述可用lambda简化

示例

读取socket数据源, 进行单词的计数

开发步骤

获取流处理运行环境

设置并行度

获取数据源

转换操作

• 以空白进行分割

• 给每个单词计数1

• 根据单词分组

求和

打印到控制台

执行任务

参考代码