@@ -147,15 +147,15 @@ Flink SQL> INSERT INTO RubberOrders SELECT product, amount FROM Orders WHERE pro
147
147
The following grammar gives an overview about the available syntax:
148
148
149
149
``` text
150
- CREATE TABLE [IF NOT EXISTS] [catalog_name.][db_name.]table_name
150
+ CREATE [TEMPORARY] TABLE [IF NOT EXISTS] [catalog_name.][db_name.]table_name
151
151
(
152
152
{ <physical_column_definition> | <metadata_column_definition> | <computed_column_definition> }[ , ...n]
153
153
[ <watermark_definition> ]
154
154
[ <table_constraint> ][ , ...n]
155
155
)
156
156
[COMMENT table_comment]
157
- [PARTITIONED BY (partition_column_name1, partition_column_name2, ...)]
158
157
[ <distribution> ]
158
+ [PARTITIONED BY (partition_column_name1, partition_column_name2, ...)]
159
159
WITH (key1=val1, key2=val2, ...)
160
160
[ LIKE source_table [( <like_options> )] | AS select_query ]
161
161
@@ -287,7 +287,7 @@ CREATE TABLE MyTable (
287
287
` timestamp` BIGINT METADATA, -- part of the query-to-sink schema
288
288
` offset` BIGINT METADATA VIRTUAL, -- not part of the query-to-sink schema
289
289
` user_id` BIGINT ,
290
- ` name` STRING,
290
+ ` name` STRING
291
291
) WITH (
292
292
' connector' = ' kafka'
293
293
...
@@ -594,7 +594,7 @@ CREATE TABLE my_ctas_table (
594
594
desc STRING,
595
595
quantity DOUBLE,
596
596
cost AS price * quantity,
597
- WATERMARK FOR order_time AS order_time - INTERVAL ' 5' SECOND,
597
+ WATERMARK FOR order_time AS order_time - INTERVAL ' 5' SECOND
598
598
) WITH (
599
599
' connector' = ' kafka' ,
600
600
...
0 commit comments