在 WindowedStream.fold() 中使用 RichFunction 时，UnsupportedOperat

Question

如何在WindowedStream.fold()方法中使用RichFoldFunction？

它总是抛出：

java.lang.UnsupportedOperationException：： FoldFunction 不能是 RichFunction。请使用fold(FoldFunction，WindowFunction(。

Answer 1

我建议您阅读此邮件列表线程，以了解为什么不允许这样做。

但是，根据您要执行的操作，即将在 Flink 1.3 中推出的 ProcessWindowFunction 可能会提供一个解决方案。