where 条件在维表中下发

Author: dapeng

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

@@ -101,6 +101,8 @@ private void parseSql(SqlNode sqlNode, Map<String, SideTableInfo> sideTableMap,
                 parseSql(unionLeft, sideTableMap, tabMapping);
                 parseSql(unionRight, sideTableMap, tabMapping);
                 break;
+            default:
+                break;
         }
     }
 
@@ -128,10 +130,10 @@ private void extractPredicateInfo(SqlNode whereNode, List<PredicateInfo> predica
 
             // 跳过函数
             if ((((SqlBasicCall) whereNode).getOperands()[0] instanceof SqlIdentifier)
-                    && (((SqlBasicCall) whereNode).getOperands()[1].getKind() != SqlKind.OTHER_FUNCTION)) {
+                    && (((SqlBasicCall) whereNode).getOperands()[1].getKind() == SqlKind.LITERAL)) {
                 fillPredicateInfoToList((SqlBasicCall) whereNode, predicatesInfoList, operatorName, operatorKind, 0, 1);
             } else if ((((SqlBasicCall) whereNode).getOperands()[1] instanceof SqlIdentifier)
-                    && (((SqlBasicCall) whereNode).getOperands()[0].getKind() != SqlKind.OTHER_FUNCTION)) {
+                    && (((SqlBasicCall) whereNode).getOperands()[0].getKind() == LITERAL)) {
                 fillPredicateInfoToList((SqlBasicCall) whereNode, predicatesInfoList, operatorName, operatorKind, 1, 0);
             }
         }