谢谢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())
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)