multi join

Author: todd5167

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

@@ -41,8 +41,6 @@ public class JoinInfo implements Serializable {
 
     //左表是否是维表
     private boolean leftIsSideTable;
-    //左表是 转换后的中间表
-    private boolean leftIsMidTable;
 
     //右表是否是维表
     private boolean rightIsSideTable;
@@ -92,21 +90,6 @@ public String getNewTableName(){
         return leftStr + "_" + rightTableName;
     }
 
-    public boolean isLeftIsMidTable() {
-        return leftIsMidTable;
-    }
-
-    public void setLeftIsMidTable(boolean leftIsMidTable) {
-        this.leftIsMidTable = leftIsMidTable;
-    }
-
-    public Map<String, String> getLeftTabMapping() {
-        return leftTabMapping;
-    }
-
-    public void setLeftTabMapping(Map<String, String> leftTabMapping) {
-        this.leftTabMapping = leftTabMapping;
-    }
 
     public String getNewTableAlias(){
         return leftTableAlias + "_" + rightTableAlias;

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

@@ -107,7 +107,7 @@ public static List<FieldInfo> getRowTypeInfo(SqlNode sqlNode, JoinScope scope, b
 
         return fieldInfoList;
     }
-
+    //TODO 丢弃多余的PROCTIME
     private static List<FieldInfo> getAllField(JoinScope scope){
         Iterator prefixId = scope.getChildren().iterator();
         List<FieldInfo> fieldInfoList = Lists.newArrayList();