- Flink原理深入與編程實戰：Scala+Java（微課視頻版）
- 辛立偉編著
- 106字
- 2023-07-17 18:54:48
3.3.6 聚合轉換
DataStream API支持各種聚合操作，例如min、max、sum等。這些聚合函數可以應用于KeyedDataStream類型的流上，以獲得滾動聚合。關于聚合轉換的簡單介紹見表3-6。
表3-6 map轉換運算
下面的示例演示了如何在Flink流上執行聚合轉換。
Scala代碼如下：
Java代碼如下：
推薦閱讀
- LabVIEW程序設計基礎與應用
- Computer Vision for the Web
- 數據結構（Python語言描述）（第2版）
- Java面向對象程序開發及實戰
- Learning Neo4j 3.x（Second Edition）
- Windows Server 2012 Unified Remote Access Planning and Deployment
- Amazon S3 Cookbook
- 微信小程序項目開發實戰
- Python Interviews
- 軟件體系結構
- Head First Kotlin程序設計
- Spring Web Services 2 Cookbook
- 自己動手構建編程語言：如何設計編譯器、解釋器和DSL
- R語言數據分析從入門到實戰
- Python全棧開發：數據分析