Skip to content

Commit 6fd5ee8

Browse files
committed
Merge remote-tracking branch 'origin/1.5_v3.6.1' into 1.5_v3.7.2
2 parents 65e1944 + 637911e commit 6fd5ee8

File tree

1 file changed

+10
-16
lines changed

1 file changed

+10
-16
lines changed

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

Lines changed: 10 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -372,39 +372,33 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
372372
return sqlIdentifier;
373373
}else if(selectNode.getKind() == LITERAL || selectNode.getKind() == LITERAL_CHAIN){//字面含义
374374
return selectNode;
375-
}else if(selectNode.getKind() == OTHER_FUNCTION
375+
}else if( AGGREGATE.contains(selectNode.getKind())
376+
|| AVG_AGG_FUNCTIONS.contains(selectNode.getKind())
377+
|| COMPARISON.contains(selectNode.getKind())
378+
|| selectNode.getKind() == OTHER_FUNCTION
376379
|| selectNode.getKind() == DIVIDE
377380
|| selectNode.getKind() == CAST
378-
|| selectNode.getKind() == SUM
379-
|| selectNode.getKind() == AVG
380-
|| selectNode.getKind() == MAX
381-
|| selectNode.getKind() == MIN
382381
|| selectNode.getKind() == TRIM
383382
|| selectNode.getKind() == TIMES
384383
|| selectNode.getKind() == PLUS
385-
|| selectNode.getKind() == IN
384+
|| selectNode.getKind() == NOT_IN
386385
|| selectNode.getKind() == OR
387386
|| selectNode.getKind() == AND
388-
|| selectNode.getKind() == COUNT
389-
|| selectNode.getKind() == SUM0
390-
|| selectNode.getKind() == LEAD
391-
|| selectNode.getKind() == LAG
392-
|| selectNode.getKind() == EQUALS
393-
|| selectNode.getKind() == NOT_EQUALS
394387
|| selectNode.getKind() == MINUS
395388
|| selectNode.getKind() == TUMBLE
396389
|| selectNode.getKind() == TUMBLE_START
397390
|| selectNode.getKind() == TUMBLE_END
398391
|| selectNode.getKind() == SESSION
399392
|| selectNode.getKind() == SESSION_START
400393
|| selectNode.getKind() == SESSION_END
394+
|| selectNode.getKind() == HOP
395+
|| selectNode.getKind() == HOP_START
396+
|| selectNode.getKind() == HOP_END
401397
|| selectNode.getKind() == BETWEEN
402398
|| selectNode.getKind() == IS_NULL
403399
|| selectNode.getKind() == IS_NOT_NULL
404-
|| selectNode.getKind() == LESS_THAN
405-
|| selectNode.getKind() == GREATER_THAN
406-
|| selectNode.getKind() == LESS_THAN_OR_EQUAL
407-
|| selectNode.getKind() == GREATER_THAN_OR_EQUAL
400+
|| selectNode.getKind() == CONTAINS
401+
408402
){
409403
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
410404
for(int i=0; i<sqlBasicCall.getOperands().length; i++){

0 commit comments

Comments
 (0)