谢谢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())
