[FLINK-14320] [FLIP-66] Support Time Attribute in SQL DDL

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Table SQL / API, Table SQL / Planner, Table SQL / Runtime
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 05/Oct/19 03:10
• Updated: 02/Apr/21 06:28
• Resolved: 02/Apr/21 06:28

Description

In Flink 1.9, we already introduced a basic SQL DDL to create a table. However, it doesn’t support to define time attributes in SQL DDL yet. Time attribute is a basic information required by time-based operations such as windows in both Table API and SQL. That means, currently, users can’t apply window operations on the tables created by DDL. Meanwhile, we received a lot of requirements from the community to define event time in DDL since 1.9 released. It will be a great benefit to support define time attribute in SQL.

This is the umbrella issue to track all the sub-tasks.

Please see the FLIP-66 for more details: https://cwiki.apache.org/confluence/display/FLINK/FLIP-66%3A+Support+Time+Attribute+in+SQL+DDL

Issue Links

• mentioned in: Page Loading...

Sub-Tasks

• Support to parse watermark statement in SQL DDL: Resolved
• Add watermark information in TableSchema: Resolved
• Convert SqlCreateTable with SqlWatermark to CatalogTable: Resolved
• Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable: Resolved
• Convert CatalogTable to TableSourceTable with additional watermark information: Closed
• Support computed column as rowtime attribute: Resolved
• Cooperate WatermarkSpec in TableSourceScan with minibatch configuration: Closed
• Fix can't create table source for Kafka if watermark or computed column is defined: Resolved
• Support nested field as the rowtime attribute: Closed
• Serialize Expression to String and parse String to Expression: Closed
• Push Projection through WatermarkAssigner: Closed