WindowedStream.fold（）でRichFunctionを使用しているときにUnsupportedOperationExceptionが発生する

Question

WindowedStream.fold()メソッドでRichFoldFunctionを使用するにはどうすればよいですか？

それは常にスロー：

java.lang.UnsupportedOperationExceptionが:: FoldFunctionはRichFunctionすることはできません。代わりにfold（FoldFunction、WindowFunction）を使用してください。

Answer 1

なぜこれが許可されていないのかについては、mailing list threadをお読みください。

しかし、何をしようとしているのかによって、まもなくFlink 1.3に来るProcessWindowFunctionが解決策を提供するかもしれません。