Skip to content

Commit bfd2fa7

Browse files
author
toutian
committed
Merge branch '1.5_v3.5.6_support_GREATER_THAN' into '1.5_v3.5.6'
support GREATER_THAN See merge request !38
2 parents f8d2d0d + 660b538 commit bfd2fa7

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -392,6 +392,10 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
392392
|| selectNode.getKind() == BETWEEN
393393
|| selectNode.getKind() == IS_NULL
394394
|| selectNode.getKind() == IS_NOT_NULL
395+
|| selectNode.getKind() == LESS_THAN
396+
|| selectNode.getKind() == GREATER_THAN
397+
|| selectNode.getKind() == LESS_THAN_OR_EQUAL
398+
|| selectNode.getKind() == GREATER_THAN_OR_EQUAL
395399
){
396400
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
397401
for(int i=0; i<sqlBasicCall.getOperands().length; i++){

0 commit comments

Comments
 (0)