使用 RichAggregateFunction 时出现 Flink 错误

Question

我正在尝试在 Flink 中使用抽象 RichAggregateFunction 的实现。我希望它“丰富”，因为我需要将一些状态存储为聚合器的一部分，而且我可以这样做，因为我可以访问运行时上下文。我的代码如下：

stream.keyBy(...)
   .window(GlobalWindows.create())
   .trigger(...)
   .aggregate(new MyRichAggregateFunction());

但是，我收到 UnsupportedOperationException 提示

此聚合函数不能是 RichFunction。

我显然没有正确使用 RichAggregateFunction。有没有如何正确使用它的例子？或者我应该使用 ProcessFunction 进行此类操作？

谢谢

Answer 1

这不是你的错误。

Flink 不支持在组窗口中扩展 RichAggregateFunction 的函数。