TableInfoParser remove sourceTableInfoMap static

Author: sishu@dtstack.com

core/src/main/java/com/dtstack/flink/sql/parser/SqlParser.java

@@ -22,7 +22,7 @@
 
 import com.dtstack.flink.sql.enums.ETableType;
 import com.dtstack.flink.sql.table.TableInfo;
-import com.dtstack.flink.sql.table.TableInfoParserFactory;
+import com.dtstack.flink.sql.table.TableInfoParser;
 import com.dtstack.flink.sql.util.DtStringUtil;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.shaded.curator.org.apache.curator.shaded.com.google.common.collect.Lists;
@@ -75,7 +75,7 @@ public static SqlTree parseSql(String sql) throws Exception {
 
         List<String> sqlArr = DtStringUtil.splitIgnoreQuota(sql, SQL_DELIMITER);
         SqlTree sqlTree = new SqlTree();
-
+        TableInfoParser tableInfoParser = new TableInfoParser();
         for(String childSql : sqlArr){
             if(Strings.isNullOrEmpty(childSql)){
                 continue;
@@ -112,7 +112,7 @@ public static SqlTree parseSql(String sql) throws Exception {
                         throw new RuntimeException("can't find table " + tableName);
                     }
 
-                    TableInfo tableInfo = TableInfoParserFactory.parseWithTableType(ETableType.SOURCE.getType(),
+                    TableInfo tableInfo = tableInfoParser.parseWithTableType(ETableType.SOURCE.getType(),
                             createTableResult, LOCAL_SQL_PLUGIN_ROOT);
                     sqlTree.addTableInfo(tableName, tableInfo);
                 }
@@ -125,7 +125,7 @@ public static SqlTree parseSql(String sql) throws Exception {
                         throw new RuntimeException("can't find table " + tableName);
                     }
 
-                    TableInfo tableInfo = TableInfoParserFactory.parseWithTableType(ETableType.SINK.getType(),
+                    TableInfo tableInfo = tableInfoParser.parseWithTableType(ETableType.SINK.getType(),
                             createTableResult, LOCAL_SQL_PLUGIN_ROOT);
                     sqlTree.addTableInfo(tableName, tableInfo);
                 }
@@ -141,7 +141,7 @@ public static SqlTree parseSql(String sql) throws Exception {
                         throw new RuntimeException("can't find table " + tableName);
                     }
 
-                    TableInfo tableInfo = TableInfoParserFactory.parseWithTableType(ETableType.SOURCE.getType(),
+                    TableInfo tableInfo = tableInfoParser.parseWithTableType(ETableType.SOURCE.getType(),
                             createTableResult, LOCAL_SQL_PLUGIN_ROOT);
                     sqlTree.addTableInfo(tableName, tableInfo);
                 }

…nk/sql/table/TableInfoParserFactory.java …ack/flink/sql/table/TableInfoParser.javacore/src/main/java/com/dtstack/flink/sql/table/TableInfoParserFactory.java renamed to core/src/main/java/com/dtstack/flink/sql/table/TableInfoParser.java core/src/main/java/com/dtstack/flink/sql/table/TableInfoParserFactory.java renamed to core/src/main/java/com/dtstack/flink/sql/table/TableInfoParser.java

@@ -42,22 +42,22 @@
  * @author xuchao
  */
 
-public class TableInfoParserFactory {
+public class TableInfoParser {
 
     private final static String TYPE_KEY = "type";
 
     private final static String SIDE_TABLE_SIGN = "(?i)^PERIOD\\s+FOR\\s+SYSTEM_TIME$";
 
     private final static Pattern SIDE_PATTERN = Pattern.compile(SIDE_TABLE_SIGN);
 
-    private static Map<String, AbsTableParser> sourceTableInfoMap = Maps.newConcurrentMap();
+    private  Map<String, AbsTableParser> sourceTableInfoMap = Maps.newConcurrentMap();
 
-    private static Map<String, AbsTableParser> targetTableInfoMap = Maps.newConcurrentMap();
+    private  Map<String, AbsTableParser> targetTableInfoMap = Maps.newConcurrentMap();
 
-    private static Map<String, AbsTableParser> sideTableInfoMap = Maps.newConcurrentMap();
+    private  Map<String, AbsTableParser> sideTableInfoMap = Maps.newConcurrentMap();
 
     //Parsing loaded plugin
-    public static TableInfo parseWithTableType(int tableType, CreateTableParser.SqlParserResult parserResult,
+    public TableInfo parseWithTableType(int tableType, CreateTableParser.SqlParserResult parserResult,
                                                String localPluginRoot) throws Exception {
         AbsTableParser absTableParser = null;
         Map<String, Object> props = parserResult.getPropMap();