按照指定的key來對流中的數據進行分組，前面入門案例中已經演示過

注意:?

流處理中沒有groupBy，而是keyBy

函數說明

KeySelector對象可以支持元組類型，也可以支持POJO

元組類型

• 單個字段keyBy

• 多個字段keyBy

上述可用lambda簡化

POJO

• 單個字段keyBy

• 多個字段keyBy

上述可用lambda簡化

示例

讀取socket數據源, 進行單詞的計數

開發(fā)步驟

獲取流處理運行環(huán)境

設置并行度

獲取數據源

轉換操作

• 以空白進行分割

• 給每個單詞計數1

• 根據單詞分組

求和

打印到控制臺

執(zhí)行任務

參考代碼