Flink的window操做之Window Functions(二)

上一篇中介绍了Flink中的window操做,接着介绍一下窗口函数.java Window Functions 在定义了窗口分配器以后呢,咱们须要为每个窗口明确的指定计算,这个就是窗口函数要作的事情,当系统决定一个窗口已经准备好执行以后，这个窗口函数将被用来处理窗口中的每个元素(多是分组的)。缓存 窗口函数能够是ReduceFunction, FoldFunction , WindowFuncti

>>阅读原文<<