小编Ani*_*lla的帖子

在数据流流世界中。

我说的时候的理解：

Window.into(FixedWindows.of(Duration.standardHours(1)))
  .triggering(AfterProcessingTime.pastFirstElementInPane()
      .plusDelayOf(Duration.standardMinutes(15))

就是对于一个小时的固定窗口，触发器在看到第一个元素之后将等待或批处理这些元素。

但是当我说：

Window.into(FixedWindows.of(Duration.standardHours(1)))
  .triggering(AfterProcessingTime.pastFirstElementInPane()

它是从第一次看到第一个元素起就每次触发，还是隐式地对元素进行批处理？因为在每个元素上触发都会使系统过载。