在 WindowedStream.fold() 中使用 RichFunction 时出现 UnsupportedOperationException

Question

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

它总是抛出：

java.lang.UnsupportedOperationException:: FoldFunction can not be a RichFunction. Please use fold(FoldFunction, WindowFunction) instead.

Answer 1

我建议您阅读此 mailing list thread 以了解为什么不允许这样做。

但是，根据您的尝试，ProcessWindowFunction 即将在 Flink 1.3 中推出，可能会提供解决方案。