在Python的Apache Beam中使用OrFinally定义自定义触发器的语法是否正确？

Question

我试图为滑动窗口定义一个自定义触发器，该窗口会对每个元素重复触发，但最终也会在水印结束时触发。我已经查阅了将近一个小时的文档，但还没有找到任何示例：（

        | beam.WindowInto(
            beam.window.SlidingWindows(60, 10),
            trigger= Repeatedly(
                (AfterCount(1), OrFinally(AfterWatermark()))
            ),
            accumulation_mode=beam.transforms.trigger.AccumulationMode.DISCARDING
        )

这就是我现在正在尝试的，显然这不起作用，但我对正确的语法非常迷茫

Answer 1

你能试着像下面那样改变触发器吗

trigger=OrFinally(Repeatedly(AfterCount(1)), AfterWatermark()),
accumulation_mode=beam.transforms.trigger.AccumulationMode.DISCARDING