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

Question

阅读了Timely (and Stateful) Processing with Apache Beam并查看了JavaDoc的Timer后，我成功设置了一个计时器来解雇。但是，我错过了如何在触发计时器之前取消它。这是Beam架构中可能/允许的语义吗？

我的背景故事是，如果没有发生某些事情，我希望注册一个计时器来触发回调...但是如果它在计时器触发之前发生了，那么我希望取消计时器被触发。

Answer 1

我没有办法取消时间。但是，您可以使用布尔值状态在计时器触发时跳过onTime处理。