分組匯總（實時任務）

1.1 版本

1.2 應用場景

資料開發-實時任務中，希望能做簡單的匯總聚合，比如求和、平均值、記錄個數。

1.3 功能簡介

新增「分組匯總」算子，支援對資料流進行實時聚合計算。如下圖所示：

1.4 注意事項

1）需要註冊實時進階算子包功能點。

2）需要配置 Flink引擎

3）5.0.1.5 及之後版本，實時任務中若使用 WebSocket輸入、MQTT輸入、IBM MQ輸入、Pulsar輸入，不能再使用分組匯總節點。

本章使用一個簡單範例，講解「分組匯總」算子如何在資料開發-實時任務中使用。

2.1 建立實時任務

進入 FineDataLink 工程，點選「資料開發>實時任務」，建立一個實時任務。如下圖所示：

2.2 資料輸入

拖入「CDC輸入」算子，設定待處理的表資料。如下圖所示：

點選「資料預覽」，如下圖所示：

2.3 分組匯總

拖入「分組匯總」算子，根據 類別ID 欄位對 產品名稱 欄位進行分組匯總。如下圖所示：

點選「資料預覽」，如下圖所示：

2.4 資料匯出

拖入「DB表匯出」算子，將資料匯出。如下圖所示：

2.5 啟動任務

點選右上角的「啟動」按鈕，啟動實時任務。啟動後，介面如下圖所示：