说明如何计算 Azure 流分析的水印

Question

我正在努力了解 Azure 流分析中的水印。根据 MS 文档，可以通过两种方式计算水印。

https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-time-handling#how-time-progresses-in-azure-stream-analytics

第二种方法声明：“当没有传入事件时，水印是当前估计到达时间减去迟到容差window。估计到达时间是从上次开始经过的时间看到一个输入事件加上该输入事件的到达时间。"

问题：

• “无传入事件”是什么意思？这是否意味着源 （例如事件中心）经验证为空？

• “最后一次看到输入事件的时间”是什么意思？做这个 是什么时候退出处理引擎到源头？

目前，我是这样解释计算的： (7) 水印 = (5) [Estimated Arrival Time] - (6) [Late Arrival Tolerance Window]

---

(5) 预计到达时间 = (1) [Elapsed Time] + (4) [Last Arrival Time]

---

(1) 已用时间 = 从 (2) [Last time an input event was last seen] 和 (3) [the current time]

开始经过的时间

Answer 1

是的“没有传入事件”意味着理想情况下 Eventhub 上没有要处理的东西。

对于第二部分，我认为您已经阅读了说明

的文档

"当没有传入事件时，水印是当前估计到达时间减去迟到容差window。估计到达时间是从上次看到输入事件时起经过的时间加上该输入事件的到达时间。” .

如果我们处于 0:45 标记，并且如果您看到预期事件发生在 :40 单位（让我们假设 事件每 5 个单位时间发生一次）。所以水印将是（在你的例子中是 45-15 (6)）

https://docs.microsoft.com/en-us/answers/questions/42145/clarification-on-how-to-calculate-watermark-for-az.html