Flink Java APIを使用してDataStream内の別個に数える方法

Question

FlinkプログラミングでHow to count unique words in a stream?と同じ問題が発生しました。しかし、その答えはScala APIを使用して問題を解決しました。 Flink Java APIサポートfilterWithStateは変換されますか？ Java APIで問題を解決できますか？

Answer 1

filterWithStateおよびmapWithStateは、Java APIで利用できないFlink Scala APIの構文砂糖のビットです。しかし、ステートフルな変換とフィルタを書き込むための基本的なメカニズムは、実際にはJavaにあります。documentationを参照してください。