浅谈如何计算Azure流分析中的水印

Question

我正致力于理解Azure流分析中的水印。根据MS文档，有两种方法可以计算水印。

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

第二种方法是：“当没有传入事件时，水印是当前估计到达时间减去延迟到达容忍窗口。估计到达时间是从最后一次看到输入事件时经过的时间加上输入事件的到达时间。”

问题：

• 什么意思“没有传入的事件”？这是否意味着来源(例如。事件中心( Event )被验证为空？

• ，什么是“最后一次看到输入事件”？这是否意味着当它将处理引擎退出到源时？

目前，我是这样解释计算的：

(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。

在第二部分中，我认为您已经通过了下面的文档

“当没有传入事件时，水印是当前估计到达时间减去延迟到达容忍窗口。估计到达时间是从上一次看到输入事件时经过的时间加上输入事件的到达时间。”

如果我们处于0:45的位置，如果您看到预期的事件位于:40单位(假设事件在每5个单位时间内发生)。所以水印是(在你的例子中是45-15 (6) )。

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