窗口API概述

在Flink流计算中，提供Window窗口API分为2种：

• Non-Keyed Windows窗口API：windowAll

  

  • 直接调用窗口函数：windowAll，然后再对窗口所有数据进行处理，未进行分组

  • 聚合操作，对窗口中数据进行聚合统计，函数：reduce、aggregate、apply() 等

    

• Keyed Windows窗口API：window

  

  • 1.数据流DataStream调用keyBy函数分组，获取KeyedStream
  • 2.KeyedStream.window设置窗口
  • 3.聚合操作，对窗口中数据进行聚合统计，函数：reduce、aggregate、apply() 等