window和time操作

window 分類：  滾動、滑動 窗口分類 滾動定義：.timeWindow(Time.seconds(5)) 滑動定義：.timeWindow(Time.seconds(5)，Time.seconds(1)) 自定義window window聚合方法：增量、全量 ● 增量聚合 窗口中每進入一條數據，就進行一次計算：使用函數如下： reduce(reduceFunction) aggregate

>>阅读原文<<