Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Support to parse watermark syntax in SQL DDL. This can implemented in flink-sql-parser module.
The watermark syntax is as following:
WATERMARK FOR columnName AS <watermark_strategy_expression>
We should also do some validation during parsing, for example, whether the referenced rowtime field exist. We should also support to reference a nested field as the rowtime field.
Attachments
Issue Links
- links to