Skip to content

Commit d079995

Browse files
committed
fix: #464 EXTRACT function
1 parent dd565a2 commit d079995

6 files changed

Lines changed: 1128 additions & 1035 deletions

File tree

src/grammar/flink/FlinkSqlParser.g4

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -789,11 +789,11 @@ primaryExpression
789789
| functionCallExpression # functionCall
790790
// | identifier '->' expression #lambda
791791
// | '(' identifier (',' identifier)+ ')' '->' expression #lambda
792-
| value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET # subscript
793-
| columnNamePath # columnReference
794-
| dereferenceDefinition # dereference
795-
| LR_BRACKET expression RR_BRACKET # parenthesizedExpression
796-
// | EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET #extract
792+
| value=primaryExpression LS_BRACKET index=valueExpression RS_BRACKET # subscript
793+
| columnNamePath # columnReference
794+
| dereferenceDefinition # dereference
795+
| LR_BRACKET expression RR_BRACKET # parenthesizedExpression
796+
| KW_EXTRACT LR_BRACKET field=identifier KW_FROM source=valueExpression RR_BRACKET # extract
797797
// | (SUBSTR | SUBSTRING) LR_BRACKET str=valueExpression (KW_FROM | COMMA) pos=valueExpression
798798
// ((KW_FOR | COMMA) len=valueExpression)? RR_BRACKET #substring
799799
// | 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)