如何取消/取消设置 DoFn 定义的计时器？

Question

阅读 Timely (and Stateful) Processing with Apache Beam and looked at the JavaDoc for a Timer 后，我已成功设置要触发的计时器。但是，我缺少如何请求在计时器触发之前将其取消。这是 Beam 架构中可能/允许的语义吗？

我的背景故事是，我希望注册一个计时器以在未发生任何事情时触发回调...但如果它在计时器触发之前发生，那么我希望取消计时器被触发.

Answer 1

我找不到取消时间的方法。但是，您可以使用布尔值状态在计时器触发时跳过处理 onTime。

Answer 2

从 Beam SDK 2.32.0 开始，您可以cancel timers。