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

remove Rbd predicate pushdown



See merge request !162

Author: toutian

impala/impala-side/impala-async-side/src/main/java/com/dtstack/flink/sql/side/impala/ImpalaAsyncSideInfo.java

@@ -64,14 +64,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
             dealOneEqualCon(sqlNode, sideTableName);
         }
 
-        List<String> whereConditionList = Lists.newArrayList();;
-        Map<String, String> physicalFields = impalaSideTableInfo.getPhysicalFields();
-        SqlNode whereNode = ((SqlSelect) joinInfo.getSelectNode()).getWhere();
-        if (whereNode != null) {
-            // 解析维表中的过滤条件
-            ParseUtils.parseSideWhere(whereNode, physicalFields, whereConditionList);
-        }
-
         sqlCondition = "select ${selectField} from ${tableName} where ";
         for (int i = 0; i < equalFieldList.size(); i++) {
             String equalField = sideTableInfo.getPhysicalFields().getOrDefault(equalFieldList.get(i), equalFieldList.get(i));
@@ -81,18 +73,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
                 sqlCondition += " and ";
             }
         }
-        if (0 != whereConditionList.size()) {
-            // 如果where条件中第一个符合条件的是维表中的条件
-            String firstCondition = whereConditionList.get(0);
-            if (!"and".equalsIgnoreCase(firstCondition) && !"or".equalsIgnoreCase(firstCondition)) {
-                whereConditionList.add(0, "and (");
-            } else {
-                whereConditionList.add(1, "(");
-            }
-            whereConditionList.add(whereConditionList.size(), ")");
-            sqlCondition += String.join(" ", whereConditionList);
-        }
-
         sqlCondition = sqlCondition.replace("${tableName}", impalaSideTableInfo.getTableName()).replace("${selectField}", sideSelectFields);
 
         boolean enablePartiton = impalaSideTableInfo.isEnablePartition();

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncSideInfo.java

@@ -72,14 +72,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
             dealOneEqualCon(sqlNode, sideTableName);
         }
 
-        List<String> whereConditionList = Lists.newArrayList();;
-        Map<String, String> physicalFields = rdbSideTableInfo.getPhysicalFields();
-        SqlNode whereNode = ((SqlSelect) joinInfo.getSelectNode()).getWhere();
-        if (whereNode != null) {
-            // 解析维表中的过滤条件
-            ParseUtils.parseSideWhere(whereNode, physicalFields, whereConditionList);
-        }
-
         sqlCondition = "select ${selectField} from ${tableName} where ";
         for (int i = 0; i < equalFieldList.size(); i++) {
             String equalField = sideTableInfo.getPhysicalFields().getOrDefault(equalFieldList.get(i), equalFieldList.get(i));
@@ -89,17 +81,6 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
                 sqlCondition += " and ";
             }
         }
-        if (0 != whereConditionList.size()) {
-            // 如果where条件中第一个符合条件的是维表中的条件
-            String firstCondition = whereConditionList.get(0);
-            if (!"and".equalsIgnoreCase(firstCondition) && !"or".equalsIgnoreCase(firstCondition)) {
-                whereConditionList.add(0, "and (");
-            } else {
-                whereConditionList.add(1, "(");
-            }
-            whereConditionList.add(whereConditionList.size(), ")");
-            sqlCondition += String.join(" ", whereConditionList);
-        }
 
         sqlCondition = sqlCondition.replace("${tableName}", rdbSideTableInfo.getTableName()).replace("${selectField}", sideSelectFields);