我正在读泰勒·阿基道的文章《the-world-beyond-batch-streaming-102》。对于水印，我仍然有点困惑，即关于文章中的代码：

PCollection<KV<String, Integer>> scores = input
  .apply(Window.into(FixedWindows.of(Duration.standardMinutes(2)))
               .triggering(AtWatermark()))

  .apply(Sum.integersPerKey());

它只是告诉引擎在水印处触发，但是引擎如何知道水印？据我所知，这应该是某种时间延迟用户需要说。或者引擎是如此智能以至于它试图为用户创建一个（根据一些默认策略或配置）？
非常感谢。