光束中大窗口的间隔触发

问题描述

我的 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 秒只触发一次的触发器？

提前致谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）