Window Function在窗口觸發后,負責對窗口內的元素進行計算。Window Function分為兩類: 增量聚合和全量聚合。
增量聚合: 窗口不維護原始數據,只維護中間結果,每次基於中間結果和增量數據進行聚合。如: ReduceFunction、AggregateFunction。
全量聚合: 窗口需要維護全部原始數據,窗口觸發進行全量聚合。如: ProcessWindowFunction。
Window Function在窗口觸發后,負責對窗口內的元素進行計算。Window Function分為兩類: 增量聚合和全量聚合。
增量聚合: 窗口不維護原始數據,只維護中間結果,每次基於中間結果和增量數據進行聚合。如: ReduceFunction、AggregateFunction。
全量聚合: 窗口需要維護全部原始數據,窗口觸發進行全量聚合。如: ProcessWindowFunction。
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。