全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

解释FlinkSQL中水印策略的不同类型及其适用场景。

提问者：帅平问题分类：面试刷题

FlinkSQL面试题 Flink

发布于：1周前 (05-28) IP属地：

1 个回答

曾经多难忘

1、固定延迟：为所有数据设置固定的延迟容忍时间，超时数据将被丢弃或归入最新窗口。

-- 示例：允许数据延迟5秒
WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND

2、有界无序：允许数据在最大延迟时间内无序到达，超时数据触发窗口计算。

-- 示例：允许最大延迟10秒
WATERMARK FOR event_time AS event_time - INTERVAL '10' SECOND

3、有界有序：数据必须按事件时间顺序到达，但允许固定延迟内延迟到达的数据参与计算。

-- 示例：允许延迟5秒，且数据必须按时间顺序
WATERMARK FOR event_time AS event_time - INTERVAL '5' SECOND

发布于：1周前 (05-28) IP属地：

我来回答