Skip to content

Commit 593015f

Browse files
committed
support replace table
1 parent 0d10f54 commit 593015f

File tree

5 files changed

+3376
-3242
lines changed

5 files changed

+3376
-3242
lines changed

docs/performance/psss/v1.18.fql

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,8 @@
1-
TRUNCATE TABLE Orders;
1+
TRUNCATE TABLE Orders;
2+
3+
4+
REPLACE TABLE my_rtas_table
5+
WITH (
6+
'connector' = 'kafka'
7+
)
8+
AS SELECT id, name, age FROM source_table WHERE mod(id, 10) = 0;

package-lock.json

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/FlinkSQLListener.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ import { SetStatememtContext } from "./FlinkSQLParser";
6060
import { ResetStatememtContext } from "./FlinkSQLParser";
6161
import { JarStatememtContext } from "./FlinkSQLParser";
6262
import { DtFilePathContext } from "./FlinkSQLParser";
63+
import { ReplaceTableContext } from "./FlinkSQLParser";
6364
import { CreateTableContext } from "./FlinkSQLParser";
6465
import { SimpleCreateTableContext } from "./FlinkSQLParser";
6566
import { CreateTableAsSelectContext } from "./FlinkSQLParser";
@@ -939,6 +940,17 @@ export interface FlinkSQLListener extends ParseTreeListener {
939940
*/
940941
exitDtFilePath?: (ctx: DtFilePathContext) => void;
941942

943+
/**
944+
* Enter a parse tree produced by `FlinkSQLParser.replaceTable`.
945+
* @param ctx the parse tree
946+
*/
947+
enterReplaceTable?: (ctx: ReplaceTableContext) => void;
948+
/**
949+
* Exit a parse tree produced by `FlinkSQLParser.replaceTable`.
950+
* @param ctx the parse tree
951+
*/
952+
exitReplaceTable?: (ctx: ReplaceTableContext) => void;
953+
942954
/**
943955
* Enter a parse tree produced by `FlinkSQLParser.createTable`.
944956
* @param ctx the parse tree

0 commit comments

Comments
 (0)