将股票价格从 Pub/Sub 流式传输到 Dataflow 中，需要每 5 秒计算一次过去 30 秒的移动平均值。您应该如何配置窗口和触发器？

要计算每 5 秒更新一次的过去 30 秒移动平均值，最适合的方法是使用滑动窗口。滑动窗口允许窗口重叠，从而实现更频繁的计算。 选项 D 是正确的，因为它指定了一个持续时间为 30 秒（覆盖过去 30 秒数据）且周期为 5 秒（每 5 秒计算一次新平均值）的滑动窗口。AfterWatermark.pastEndOfWindow() 是处理时间语义下，当所有预期数据都已到达窗口结束时触发计算的标准方式，确保结果的完整性。 选项 A 和 B 使用固定窗口，这不适用于需要频繁更新的移动平均值。固定窗口是离散的，不重叠。 选项 C 的滑动窗口配置不正确，它将持续时间设为 5 秒，而题目要求的是 30 秒的移动平均值，并且其触发器 AfterProcessingTime.pastFirstElementInPane().plusDelayOf(Duration.standardSeconds(30)) 过于复杂且不适合此场景。