特牛网址导航

【Flink】Flink中的窗口API、窗口函数以及迟到数据处理问题_tumblingprocessingtimewindows.of-CSDN博客

网友收藏
文章浏览阅读2.3k次。在流处理中,我们往往需要面对的是连续不断、无休无止的无界流,不可能等到所有所有数据都到齐了才开始处理。更加高效的做法是,把无界流进行切分,每一段数据分别进行聚合,结果只输出一次。这就相当于将无界流的聚合转化为了有界数据集的聚合,这就是所谓的“窗口”(Window)聚合操作。窗口聚合其实是对实时性和处理效率的一个权衡。_tumblingprocessingtimewindows.of