我在寻找清晰的文档和/或和示例如何设置在Apache的光束全局窗口基于时间触发。
目的是为了执行事件的计数自上次触发解雇,即使0事件以来已增加。
您可以使用计时器和状态,如果你需要使用全局窗口,并发出即使有自上次发射没有事件的结果。我认为这是不可能的,内置的触发器来做到这一点。
你可以保持计数状态,并用一个定时器定期发出的结果。这两个博客文章解释器和状态的用法:
Stateful processing with Apache Beam
Timely (and Stateful) Processing with Apache Beam