Ma Jun created FLINK-22827: ------------------------------ Summary: 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
{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)