diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java b/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java index 5ebc7fe423..e285cb6caa 100644 --- a/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java +++ b/chunjun-core/src/main/java/com/dtstack/chunjun/util/ConnectorNameConvertUtil.java @@ -37,38 +37,11 @@ public class ConnectorNameConvertUtil { connectorNameMap.put("restapi", new Tuple3<>("http", "http", "http")); connectorNameMap.put( "adbpostgresql", new Tuple3<>("postgresql", "postgresql", "postgresql")); - connectorNameMap.put("metadatamysql", new Tuple3<>("mysql", "metaDataMysql", "mysql")); - connectorNameMap.put("metadatakafka", new Tuple3<>("kafka", "metaDataKafka", "kafka")); - connectorNameMap.put( - "metadatavertica", new Tuple3<>("vertica", "metaDataVertica", "vertica")); - connectorNameMap.put( - "metadatahbase", new Tuple3<>("hbase14", "metaDataHBase14", "hbase14")); - connectorNameMap.put("metadatahive2", new Tuple3<>("hive", "metaDataHive", "hive")); - connectorNameMap.put("metadatahive1", new Tuple3<>("hive1", "metaDataHive1", "hive1")); - connectorNameMap.put( - "metadatasparkthrift", - new Tuple3<>("sparkthrift", "metaDataSparkThrift", "sparkthrift")); - connectorNameMap.put( - "metadatasqlserver", new Tuple3<>("sqlserver", "metaDataSqlServer", "sqlserver")); - connectorNameMap.put("metadataoracle", new Tuple3<>("oracle", "metaDataOracle", "oracle")); - connectorNameMap.put( - "metadataphoenix5", new Tuple3<>("phoenix5", "metaDataPhoenix5", "phoenix5")); - connectorNameMap.put("metadatahive1cdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive")); - connectorNameMap.put("metadatahive2cdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive")); - connectorNameMap.put( - "metadatasparkthriftcdc", new Tuple3<>("hive", "metaDataHiveCdc", "hive")); - connectorNameMap.put("metadatatidb", new Tuple3<>("tidb", "metaDataTidb", "tidb")); + connectorNameMap.put("dorisbatch", new Tuple3<>("doris", "doris", "doris")); connectorNameMap.put("starrocks", new Tuple3<>("starrocks", "starRocks", null)); connectorNameMap.put("gbase", new Tuple3<>("gbase", "gBase", null)); connectorNameMap.put("protobuf", new Tuple3<>("pbformat", "pbformat", null)); - connectorNameMap.put("huaweihbase", new Tuple3<>("huaweihbase", "huaweiHbase", null)); - connectorNameMap.put("huaweihdfs", new Tuple3<>("huaweihdfs", "huaweiHdfs", null)); - connectorNameMap.put("pgwal", new Tuple3<>("pgwal", "PGWal", null)); - connectorNameMap.put("kafka-hw", new Tuple3<>("huaweikafka", "huaweikafka", null)); - connectorNameMap.put("hudi", new Tuple3<>("hudi", "hoodie", null)); - connectorNameMap.put( - "inceptorhyperbase", new Tuple3<>("inceptorhyperbase", "DirectHyperbase", null)); } public static String convertClassPrefix(String originName) {