热门标签
更多>
搜索结果
查询Tags标签: Lateness,共有 2条记录-
FLINK基础(115): DS算子与窗口(24)窗口 (9) Allowed Lateness
1 使用迟到元素更新窗口计算结果(Updating Results by Including Late Events) 由于存在迟到的元素,所以已经计算出的窗口结果是不准确和不完全的。我们可以使用迟到元素更新已经计算完的窗口结果。 如果我们要求一个operator支持重新计算和更新已经发出的结果,就需要在…
2021/8/24 23:37:09 人评论 次浏览 -
FLINK基础(115): DS算子与窗口(24)窗口 (9) Allowed Lateness
1 使用迟到元素更新窗口计算结果(Updating Results by Including Late Events) 由于存在迟到的元素,所以已经计算出的窗口结果是不准确和不完全的。我们可以使用迟到元素更新已经计算完的窗口结果。 如果我们要求一个operator支持重新计算和更新已经发出的结果,就需要在…
2021/8/24 23:37:09 人评论 次浏览