ivywenyuan
Reputation: 39
How to use Flink Java API to count distinct in a DataStream
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
Answers (1)
David Anderson
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
Related Questions
- How can I improve my count distinct for data stream implementation in Flink?
- How to count total records read in source using Flink dataset API
- Apache Flink DataStream - Count of Element in Tumbling Window
- Filtering unique events in apache flink
- Flink streaming, how to do the counting?
- List Distinct elements including a count with Java Streams
- Count distinct in infinite stream
- Apache Flink: How to count the total number of events in a DataStream
- How to count unique words in a stream?
- How to count by property and time window with Apache Flink?