Skip to content

Commit 16dcaf2

Browse files
author
mumiao
authored
Merge pull request DTStack#141 from HaydenOrz/fix/flink_sql_grammar
Fix/flink sql grammar
2 parents f1ca073 + 9bd842b commit 16dcaf2

File tree

10 files changed

+5452
-5380
lines changed

10 files changed

+5452
-5380
lines changed

src/grammar/flinksql/FlinkSqlLexer.g4

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,7 @@ KW_CHECK: 'CHECK';
227227
KW_CLOB: 'CLOB';
228228
KW_CLOSE: 'CLOSE';
229229
KW_COALESCE: 'COALESCE';
230+
KW_CONFIG: 'CONFIG';
230231
KW_COLLATE: 'COLLATE';
231232
KW_COLLECT: 'COLLECT';
232233
KW_COLUMN: 'COLUMN';

src/grammar/flinksql/FlinkSqlParser.g4

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@ dtAddStatement
9797
| KW_ADD (KW_PYTHON_FILES | KW_PYTHON_REQUIREMENTS | KW_PYTHON_DEPENDENCIES | KW_PYTHON_JAR | KW_PYTHON_ARCHIVES) KW_WITH dtFilePath KW_RENAME uid
9898
| KW_ADD KW_PYTHON_PARAMETER dtFilePath
9999
| KW_ADD KW_ENGINE KW_FILE KW_WITH dtFilePath KW_RENAME uid KW_KEY uid
100+
| KW_ADD KW_CONFIG KW_FILE KW_WITH dtFilePath KW_FOR uid KW_AS uid
100101
;
101102

102103
dtFilePath
@@ -1023,6 +1024,8 @@ reservedKeywordsUsedAsFuncName
10231024
| KW_POSITION
10241025
| KW_POWER
10251026
| KW_QUARTER
1027+
| KW_ROW
1028+
| KW_ROWS
10261029
| KW_RANK
10271030
| KW_RIGHT
10281031
| KW_SECOND

src/lib/flinksql/FlinkSqlLexer.interp

Lines changed: 4 additions & 1 deletion
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)