如何替换 KeyedStreams 上已弃用的折叠功能

Question

Flink KeyedStreams 上的 fold 函数已弃用。 aggregate 函数是私有的，而且仅限于某些预定义的聚合类型。

WindowedStreams 上提供了一个很好的聚合实现。所以我可以做的是用某种 AlwaysOnElementTrigger 定义一个 GlobalWindow （在每个元素上触发）。这对我来说有点不对劲，但我看不出有什么缺点。

我的问题：我是否必须忍受弃用警告，或者 GlobalWindow 解决方法是否有点难看但能满足我的要求？

Answer 1

RichFlatMapFunction 或 KeyedProcessFunction 感觉更直接。