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?
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?