使用RichAggregateFunction时出现Flink错误

Question

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

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

但是，我得到一个UnsupportedOperationException说

此聚合函数不能是RichFunction。

我显然没有正确使用RichAggregateFunction。有任何如何正确使用它的示例吗？还是应该将ProcessFunction用于此类操作？

谢谢

Answer 1

这不是您的错误。

Flink不支持RichAggregateFunction在组窗口中扩展的功能。