我正在寻找关于如何在apachebeam的全局窗口上设置基于时间的触发器的清晰文档和/或示例。其目的是对自上次触发以来的事件进行计数，即使此后添加了0个事件。
hc8w905p1#
如果需要使用全局窗口并发出结果（即使自上次触发后没有任何事件），也可以使用计时器和状态。我认为使用内置触发器是不可能的。您可以将计数保持在某个状态，并使用计时器定期发出结果。这两篇博文解释了计时器和状态的用法：apache梁的状态处理使用apache beam进行及时（有状态）处理
1条答案
按热度按时间hc8w905p1#
如果需要使用全局窗口并发出结果（即使自上次触发后没有任何事件），也可以使用计时器和状态。我认为使用内置触发器是不可能的。
您可以将计数保持在某个状态，并使用计时器定期发出结果。这两篇博文解释了计时器和状态的用法：
apache梁的状态处理
使用apache beam进行及时（有状态）处理