Apache Beam窗口:考虑较晚的数据,但仅发出一个窗格

Apache Beam窗口:考虑较晚的数据,但仅发出一个窗格,第1张

Apache Beam窗口:考虑较晚的数据,但仅发出一个窗格

谢谢Guillem,最后我用您的答案找到了这个非常有用的链接,其中包含许多apap
beam示例。由此,我提出了以下解决方案:

 // We first specify to never emit any panes .triggering(Never.ever()) // We then specify to fire always when closing the window. This will emit a // single final pane at the end of allowedLateness .withAllowedLateness(allowedLateness, Window.ClosingBehavior.FIRE_ALWAYS) .discardingFiredPanes())


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5500367.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-13
下一篇 2022-12-13

发表评论

登录后才能评论

评论列表(0条)

保存