Merge branch 'v1.8.0_dev_feature_kudu_parse' into 'v1.8.0_dev'

解决kudu cache=all模式 not compare operator问题

解决kudu cache=all模式 not compare operator问题

See merge request !140

Author: simenliuxing

kudu/kudu-side/kudu-all-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAllSideInfo.java

@@ -5,6 +5,7 @@
 import com.dtstack.flink.sql.side.SideInfo;
 import com.dtstack.flink.sql.side.SideTableInfo;
 import com.dtstack.flink.sql.side.kudu.table.KuduSideTableInfo;
+import com.dtstack.flink.sql.util.ParseUtils;
 import org.apache.calcite.sql.SqlBasicCall;
 import org.apache.calcite.sql.SqlKind;
 import org.apache.calcite.sql.SqlNode;
@@ -61,11 +62,7 @@ public void parseSelectFields(JoinInfo joinInfo) {
         SqlNode conditionNode = joinInfo.getCondition();
 
         List<SqlNode> sqlNodeList = Lists.newArrayList();
-        if (conditionNode.getKind() == SqlKind.AND) {
-            sqlNodeList.addAll(Lists.newArrayList(((SqlBasicCall) conditionNode).getOperands()));
-        } else {
-            sqlNodeList.add(conditionNode);
-        }
+        ParseUtils.parseAnd(conditionNode, sqlNodeList);
 
         for (SqlNode sqlNode : sqlNodeList) {
             dealOneEqualCon(sqlNode, sideTableName);