请问Pyflink中DataStream API用于Batch Mode可以像table api一样输出最终结果吗？

[Arcadia]

计算逻辑是key_by后count，拿到结果后sink

尝试用keyedProcessFunction实现，但是不知道怎么实现在数据全部记录后再输出结果