我注意到 TumblingProcessingTimeWindows 哪个 extends WindowAssigner 创建 TimeWindow 对于每个元素。源代码 TumblingProcessingTimeWindows#assignWindows :

@Override
public Collection<TimeWindow> assignWindows(Object element, long timestamp, WindowAssignerContext context) {
    final long now = context.getCurrentProcessingTime();
    long start = TimeWindow.getWindowStartWithOffset(now, offset, size);
    return Collections.singletonList(new TimeWindow(start, start + size));
}

我的问题是，这有必要吗？为什么不用同样的 TimeWindow 所有属于它的元素？