Flink KeyedStreams上的fold函数已被弃用。aggregate函数是私有的，此外仅限于某些预定义的聚合类型。
WindowedStreams 上提供了一个很好的聚合实现。所以我能做的是用某种AlwaysOnElementTrigger定义一个GlobalWindow(在每个元素上触发(。这对我来说不知何故感觉不对劲，但我看不到缺点。
的问题：我是否必须忍受弃用警告，或者GlobalWindow解决方法只是有点丑陋，但做了我想要的？
RichFlatMapFunction或KeyedProcessFunction感觉像是一种更直接的方法。