可以對一個 dataset 或者一個 group 來進行聚合計算，最終聚合成一個元素

示例

讀取apache.log日志，統(tǒng)計ip地址訪問pv數(shù)量，使用 reduce 操作聚合成一個最終結果

結果類似：

(86.149.9.216,1)

(10.0.0.1,7)

(83.149.9.216,6)

步驟

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

使用 readTextFile 構建數(shù)據(jù)源

使用 reduce 執(zhí)行聚合操作

打印測試

參考代碼