光束中大窗口的间隔触发

如何解决光束中大窗口的间隔触发

我的 Beam 管道使用大事件时间窗口来计算数据的平均值和进一步统计数据，其中每秒我都会收到一个新事件。我使用 Kafka 作为我的流媒体源。 但是，我确实想在给定的时间间隔内发出早期结果。 我正在使用以下窗口和触发器。

.apply(Window
            .into(SlidingWindows.of(duration).every(advance))
            .triggering(AfterWatermark.pastEndOfWindow()
                .withEarlyFirings(
                    AfterProcessingTime.pastFirstElementInPane().plusDelayOf(triggerDelay)))
            .withAllowedLateness(Duration.ZERO)
            .accumulatingFiredPanes())

就我获得早期结果而言，这是有效的。然而，我确实通过相同的计算获得每个 triggerDelay 的多个输出，而不是直到这个时间点的窗口的单个结果。 如下所示：

Stats{count=209,mean=10.0,populationStandardDeviation=0.0,min=10.0,max=10.0}
Stats{count=209,max=10.0}
...
...
Stats{count=209,max=10.0}

是否有可能为每个到达的事件触发早期触发触发器，而不是在 triggerDelay 之后触发一次？有没有办法定义每 x 秒只触发一次的触发器？

提前致谢