Reputation: 39
I met with the same problem as How to count unique words in a stream? in Flink programming. However, the answer used Scala API to solve the problem. Does Flink Java API support filterWithState
transform ? Can Java API solve the problem?
Upvotes: 3
Views: 1729
Reputation: 43717
filterWithState
and mapWithState
are bits of syntactic sugar for the Flink Scala API that aren't available in the Java API. But the underlying mechanisms for writing stateful transformations and filters are indeed there in Java -- see the documentation.
Upvotes: 1