在《0基础学习PyFlink——个数滚动窗口(Tumbling Count Windows)》一文中，我们发现如果窗口内元素个数没有达到窗口大小时，计算个数的函数是不会被调用的。如下图中红色部分 那么有没有办法让上图中（B,2）和（D,5）也会被计算呢？ 这就可以使用本节介绍的时间滚动窗口。它不依赖于窗口中元素的个数，而是窗口的时间，即窗口时间到了，计算就会进行。 我们稍微修改下《0基础学习PyFlink——个数滚动窗口(Tumbling Count Windows)》的例子，让元素集中在“A”上。 map class SumWindowFunction(WindowFunction[tuple, tuple, str, TimeWindow]): def apply(self, key: str, window: TimeWindow, inputs: Iterable[tuple]): print(*inputs, window) return [(key, len([e for e in inputs]))] word_count_data =...
