[FLINK-10232] Add a SQL DDL

• Type: New Feature
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: Timo Walther
• Created: 28/Aug/18 08:31
• Updated: 27/Dec/21 10:47

Description

This is an umbrella issue for all efforts related to supporting a SQL Data Definition Language (DDL) in Flink's Table & SQL API.

Such a DDL includes creating, deleting, replacing:

• tables
• views
• functions
• types
• libraries
• catalogs

If possible, the parsing/validating/logical part should be done using Calcite. Related issues are CALCITE-707, CALCITE-2045, CALCITE-2046, CALCITE-2214, and others.

Issue Links

• Blocked: FLINK-12557 Improve the DDL property keys to be more concise and readble
• is a parent of: FLINK-7151 Support function DDL
• is related to: FLINK-10556 Integration with Apache Hive
• links to: Flink SQL DDL design doc

Sub-Tasks

• Add a type SQL DDL: Open
• Add a view SQL DDL: Resolved
• Add a create table SQL DDL: Closed
• Add insert into partition grammar as hive dialect: Closed
• Add insert overwrite grammar as HIVE dialect: Closed
• Add logic to bridge DDL to table source(sink): Closed
• Supports create(drop) view grammar for sql parser: Closed
• Add a stream specific CREATE TABLE SQL DDL: Closed