[
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355014#comment-17355014
]
Ma Jun edited comment on FLINK-22827 at 6/1/21, 11:14 AM:
----------------------------------------------------------
Hi [~joemoe], In our project, we mainly use the Flink planner to make a SQL
verification judgment, and then we can let users submit the Flink SQL directly.
because our environment is mainly the table hive environment, because I know
whether the future Flink SQL parser intends to support this. In the
flink-sql-parser-hive unit test, cluterered by is the TODO state.Now we have
expanded the syntax support of createtable by modifying it, so we want to ask
if the community needs to join in?
was (Author: aidenma):
Hi [~joemoe], In our project, we mainly use the Flink planner to make a SQL
verification judgment, and then we can let users submit the Flink SQL directly,
because our environment is mainly the table hive environment, because I know
whether the future Flink SQL parser intends to support this. In the
flink-sql-parser-hive unit test, cluterered by is the TODO state.Now we have
expanded the syntax support of createtable by modifying it, so we want to ask
if the community needs to join in?
> Hive CREATE TABLE Support CLUSTERED BY
> --------------------------------------
>
> Key: FLINK-22827
> URL: https://issues.apache.org/jira/browse/FLINK-22827
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
> Affects Versions: 1.13.1
> Reporter: Ma Jun
> Priority: Major
>
> {code:java}
> # hive syntax:
> CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] table_identifier
> [ ( col_name1[:] col_type1 [ COMMENT col_comment1 ], ... ) ]
> [ COMMENT table_comment ]
> [ PARTITIONED BY ( col_name2[:] col_type2 [ COMMENT col_comment2 ], ... )
> | ( col_name1, col_name2, ... ) ]
> [ CLUSTERED BY ( col_name1, col_name2, ...)
> [ SORTED BY ( col_name1 [ ASC | DESC ], col_name2 [ ASC | DESC ], ...
> ) ]
> INTO num_buckets BUCKETS ]
> [ ROW FORMAT row_format ]
> [ STORED AS file_format ]
> [ LOCATION path ]
> [ TBLPROPERTIES ( key1=val1, key2=val2, ... ) ]
> [ AS select_statement ]
> {code}
>
> {code:java}
> [ CLUSTERED BY ( col_name1, col_name2, ...) [ SORTED BY ( col_name1 [ ASC |
> DESC ], col_name2 [ ASC | DESC ], ... ) ]
> {code}
> Will Flink support the way of creating tables and supporting clustered by |
> sort by into buckets in later versions？
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
