Skip to content

Commit 98aa150

Browse files
committed
Merge remote-tracking branch 'origin/1.5_v3.7.2' into 1.5_v3.8.0_beta_1.0
2 parents 6b504ff + 6fd5ee8 commit 98aa150

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
@@ -439,39 +439,33 @@ private SqlNode replaceSelectFieldName(SqlNode selectNode, HashBasedTable<String
439439
return sqlIdentifier;
440440
}else if(selectNode.getKind() == LITERAL || selectNode.getKind() == LITERAL_CHAIN){//字面含义
441441
return selectNode;
442-
}else if(selectNode.getKind() == OTHER_FUNCTION
442+
}else if( AGGREGATE.contains(selectNode.getKind())
443+
|| AVG_AGG_FUNCTIONS.contains(selectNode.getKind())
444+
|| COMPARISON.contains(selectNode.getKind())
445+
|| selectNode.getKind() == OTHER_FUNCTION
443446
|| selectNode.getKind() == DIVIDE
444447
|| selectNode.getKind() == CAST
445-
|| selectNode.getKind() == SUM
446-
|| selectNode.getKind() == AVG
447-
|| selectNode.getKind() == MAX
448-
|| selectNode.getKind() == MIN
449448
|| selectNode.getKind() == TRIM
450449
|| selectNode.getKind() == TIMES
451450
|| selectNode.getKind() == PLUS
452-
|| selectNode.getKind() == IN
451+
|| selectNode.getKind() == NOT_IN
453452
|| selectNode.getKind() == OR
454453
|| selectNode.getKind() == AND
455-
|| selectNode.getKind() == COUNT
456-
|| selectNode.getKind() == SUM0
457-
|| selectNode.getKind() == LEAD
458-
|| selectNode.getKind() == LAG
459-
|| selectNode.getKind() == EQUALS
460-
|| selectNode.getKind() == NOT_EQUALS
461454
|| selectNode.getKind() == MINUS
462455
|| selectNode.getKind() == TUMBLE
463456
|| selectNode.getKind() == TUMBLE_START
464457
|| selectNode.getKind() == TUMBLE_END
465458
|| selectNode.getKind() == SESSION
466459
|| selectNode.getKind() == SESSION_START
467460
|| selectNode.getKind() == SESSION_END
461+
|| selectNode.getKind() == HOP
462+
|| selectNode.getKind() == HOP_START
463+
|| selectNode.getKind() == HOP_END
468464
|| selectNode.getKind() == BETWEEN
469465
|| selectNode.getKind() == IS_NULL
470466
|| selectNode.getKind() == IS_NOT_NULL
471-
|| selectNode.getKind() == LESS_THAN
472-
|| selectNode.getKind() == GREATER_THAN
473-
|| selectNode.getKind() == LESS_THAN_OR_EQUAL
474-
|| selectNode.getKind() == GREATER_THAN_OR_EQUAL
467+
|| selectNode.getKind() == CONTAINS
468+
475469
){
476470
SqlBasicCall sqlBasicCall = (SqlBasicCall) selectNode;
477471
for(int i=0; i<sqlBasicCall.getOperands().length; i++){

0 commit comments

Comments
 (0)