在fold上弗林克的功能KeyedStreams已被弃用。该aggregate函数是私有的，而且仅限于一些预定义的聚合类型。
上提供了一个很好的聚合实现WindowedStreams。所以我能做的是GlobalWindow用某种AlwaysOnElementTrigger（在每个元素上触发）定义一个。不知何故，我感觉不对，但我看不到缺点。
我的问题：我是否必须忍受弃用警告，还是GlobalWindow解决方法有点难看但是否符合我的要求？
A RichFlatMapFunctionorKeyedProcessFunction感觉像是一种更直接的方法。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句