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?
Asked
Active
Viewed 1,645 times
3
ivywenyuan
- 39
- 3
1 Answers
1
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.
David Anderson
- 39,434
- 4
- 33
- 60