【发布时间】：2019-12-09 17:30:18
【问题描述】：
我对 Apache Flink 及其 API 非常陌生。我想创建一个 Java 程序，该程序将使用滚动窗口进行基于事件时间的处理。我想计算给定窗口中的元素数量。但是，我不知道该怎么做。
【问题讨论】：
【发布时间】：2019-12-09 17:30:18
【问题描述】：
所以，如果要计算窗口中的元素个数，大概最简单的思路就是这样。假设您有代表您的数据集的 dataset 变量：
dataset.map(element => (element,1)).timeWindowAll(Time.seconds(5)).sum(1)
这应该给你窗口中元素的数量。
【讨论】：