如何使用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是Flink Scala API的一些語法糖，它們在Java API中不可用。但是編寫有狀態轉換和過濾器的底層機制確實存在於Java中 - 請參閱documentation。