How to count the number of records processed by Apache Flink in a given time window

Viewed 4606

After defining a time window in flink as follows:

val lines = socket.timeWindowAll(Time.seconds(5))

How can I compute the number of records in that particular window of 5 seconds?

2 Answers
Related