Skip to content

Commit b13f619

Browse files
committed
support row, map, array type in select statement
1 parent d3bade3 commit b13f619

9 files changed

Lines changed: 5426 additions & 5500 deletions

File tree

gen/.antlr/FlinkSQL.interp

Lines changed: 1 addition & 2 deletions
Large diffs are not rendered by default.

gen/.antlr/FlinkSQLParser.java

Lines changed: 2553 additions & 2569 deletions
Large diffs are not rendered by default.

gen/FlinkSQL.g4

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -743,20 +743,17 @@ complexDataTypeExpression
743743
;
744744

745745
arrayExpression
746-
: KW_ARRAY LS_BRACKET dataTypeExpression RS_BRACKET
746+
: KW_ARRAY LS_BRACKET dataTypeExpression (COMMA dataTypeExpression)* RS_BRACKET
747747
;
748748

749749
rowExpression
750-
: KW_ROW LR_BRACKET rowFieldExpression (COMMA rowFieldExpression)* RR_BRACKET
750+
: KW_ROW LR_BRACKET dataTypeExpression (COMMA dataTypeExpression)* RR_BRACKET
751751
;
752752

753753
mapExpression
754754
: KW_MAP LS_BRACKET dataTypeExpression COMMA dataTypeExpression RS_BRACKET
755755
;
756756

757-
rowFieldExpression
758-
: dataTypeExpression KW_AS identifier
759-
;
760757

761758
dataTypeExpression
762759
: columnAlias

gen/FlinkSQL.interp

Lines changed: 1 addition & 2 deletions
Large diffs are not rendered by default.

out/extension.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

out/extension.js.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/FlinkSQLListener.ts

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,6 @@ import { ComplexDataTypeExpressionContext } from "./FlinkSQLParser";
178178
import { ArrayExpressionContext } from "./FlinkSQLParser";
179179
import { RowExpressionContext } from "./FlinkSQLParser";
180180
import { MapExpressionContext } from "./FlinkSQLParser";
181-
import { RowFieldExpressionContext } from "./FlinkSQLParser";
182181
import { DataTypeExpressionContext } from "./FlinkSQLParser";
183182
import { FunctionNameContext } from "./FlinkSQLParser";
184183
import { FunctionParamContext } from "./FlinkSQLParser";
@@ -2237,17 +2236,6 @@ export interface FlinkSQLListener extends ParseTreeListener {
22372236
*/
22382237
exitMapExpression?: (ctx: MapExpressionContext) => void;
22392238

2240-
/**
2241-
* Enter a parse tree produced by `FlinkSQLParser.rowFieldExpression`.
2242-
* @param ctx the parse tree
2243-
*/
2244-
enterRowFieldExpression?: (ctx: RowFieldExpressionContext) => void;
2245-
/**
2246-
* Exit a parse tree produced by `FlinkSQLParser.rowFieldExpression`.
2247-
* @param ctx the parse tree
2248-
*/
2249-
exitRowFieldExpression?: (ctx: RowFieldExpressionContext) => void;
2250-
22512239
/**
22522240
* Enter a parse tree produced by `FlinkSQLParser.dataTypeExpression`.
22532241
* @param ctx the parse tree

0 commit comments

Comments
 (0)