在Apache中梁全局窗口基于时间的触发

问题描述 投票:2回答:1

我在寻找清晰的文档和/或和示例如何设置在Apache的光束全局窗口基于时间触发。

目的是为了执行事件的计数自上次触发解雇,即使0事件以来已增加。

google-cloud-dataflow apache-flink apache-beam
1个回答
2
投票

您可以使用计时器和状态,如果你需要使用全局窗口,并发出即使有自上次发射没有事件的结果。我认为这是不可能的,内置的触发器来做到这一点。

你可以保持计数状态,并用一个定时器定期发出的结果。这两个博客文章解释器和状态的用法:

Stateful processing with Apache Beam

Timely (and Stateful) Processing with Apache Beam

© www.soinside.com 2019 - 2024. All rights reserved.