我对ApacheFlink及其api非常陌生，我想创建一个java程序，它可以在翻滚的窗口中进行基于事件时间的处理。我要计算给定窗口中的元素数。然而，我不知道怎么做。
ebdffaop1#
所以，如果你想计算窗口中元素的数量，最简单的方法可能是这样。假设你有 dataset 表示数据集的变量：
dataset
dataset.map(element => (element,1)).timeWindowAll(Time.seconds(5)).sum(1)
这将为您提供窗口中元素的数量。
1条答案
按热度按时间ebdffaop1#
所以，如果你想计算窗口中元素的数量，最简单的方法可能是这样。假设你有
dataset表示数据集的变量：这将为您提供窗口中元素的数量。