小编Ani*_*Das的帖子

在flink中定义一个时间窗口后如下：

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

如何计算该特定 5 秒窗口内的记录数？