java - 使用 RichAggregateFunction 时出现 Flink 错误

Question

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

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

但是，我得到一个 UnsupportedOperationException 说

This aggregation function cannot be a RichFunction.

我显然没有正确使用 RichAggregateFunction。有没有正确使用它的例子？或者我应该为这种操作使用 ProcessFunction 吗？

谢谢

Answer 1

这不是您的错误。

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