| 作用 | 触发+清理 |
|---|---|
| 设置 | max out of orderness |
| 权衡 | 延迟与完整度 |
| 边界 | 超期数据进入侧输出 |
水位线设置
水位线设置
CREATE TABLE orders (
order_id STRING,
store_id STRING,
pay_amt DECIMAL(18,2),
event_time TIMESTAMP(3),
WATERMARK FOR event_time AS event_time - INTERVAL '10' SECOND
) WITH (
'connector' = 'kafka',
'topic' = 'trade_events',
'properties.bootstrap.servers' = 'broker:9092',
'format' = 'json'
);水位线延迟设得过大，窗口结果出炉变慢；过小则迟到数据被丢弃。