1 个回答
Flink中提供的watermark策略主要有3种,分别是:
1.严格意义上递增的时间戳,发出到目前为止已观察到的最大时间戳的水印。时间戳小于最大时间戳的行不会迟到。 WATERMARK FOR rowtime_column AS rowtime_column
2.递增的时间戳,发出到目前为止已观察到的最大时间戳为负1的水印。时间戳等于或小于最大时间戳的行不会迟到。 WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL '0.001' SECOND。
3.有界时间戳(乱序) 发出水印,它是观察到的最大时间戳减去指定的延迟,例如,WATERMARK FOR rowtime_column AS rowtime_column-INTERVAL'5'SECOND是5秒的延迟水印策略。 WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL 'string' timeUnit.
发布于:1年前 (2023-07-31) IP属地:四川省
我来回答
您需要 登录 后回答此问题!