Skip to content

Commit c1b9d17

Browse files
committed
fix: #464 EXTRACT function
1 parent 0cb6af6 commit c1b9d17

File tree

6 files changed

+1274
-1182
lines changed

6 files changed

+1274
-1182
lines changed

src/grammar/flink/FlinkSqlParser.g4

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -803,11 +803,11 @@ primaryExpression
803803
| functionCallExpression # functionCall
804804
// | identifier '->' expression #lambda
805805
// | '(' identifier (',' identifier)+ ')' '->' expression #lambda
806-
| value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET # subscript
807-
| columnNamePath # columnReference
808-
| dereferenceDefinition # dereference
809-
| LR_BRACKET expression RR_BRACKET # parenthesizedExpression
810-
// | EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET #extract
806+
| value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET # subscript
807+
| columnNamePath # columnReference
808+
| dereferenceDefinition # dereference
809+
| LR_BRACKET expression RR_BRACKET # parenthesizedExpression
810+
| KW_EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET # extract
811811
// | (SUBSTR | SUBSTRING) LR_BRACKET str=valueExpression (KW_FROM | COMMA) pos=valueExpression
812812
// ((KW_FOR | COMMA) len=valueExpression)? RR_BRACKET #substring
813813
// | TRIM LR_BRACKET trimOption=(BOTH | LEADING | TRAILING)? (trimStr=valueExpression)?

src/lib/flink/FlinkSqlParser.interp

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

0 commit comments

Comments
 (0)