Skip to content

Commit 1614b87

Browse files
committed
support timestamp_add
1 parent 0607095 commit 1614b87

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -520,6 +520,8 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
520520
|| selectNode.getKind() == IS_NULL
521521
|| selectNode.getKind() == IS_NOT_NULL
522522
|| selectNode.getKind() == CONTAINS
523+
|| selectNode.getKind() == TIMESTAMP_ADD
524+
|| selectNode.getKind() == TIMESTAMP_DIFF
523525

524526
){
525527
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

core/src/main/java/com/dtstack/flink/sql/util/ParseUtils.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,8 @@ public static SqlNode replaceSelectFieldTabName(SqlNode selectNode, Map<String,S
159159
|| selectNode.getKind() == IS_NULL
160160
|| selectNode.getKind() == IS_NOT_NULL
161161
|| selectNode.getKind() == CONTAINS
162+
|| selectNode.getKind() == TIMESTAMP_ADD
163+
|| selectNode.getKind() == TIMESTAMP_DIFF
162164

163165
){
164166
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;

0 commit comments

Comments
 (0)