static

in seatunnel-datasource/seatunnel-datasource-client/src/main/java/org/apache/seatunnel/datasource/classloader/DatasourceLoadConfig.java [47:133]

• 84 lines of code
• 1 McCabe index (conditional complexity)

    static {
        classLoaderFactoryName = new HashMap<>();
        classLoaderJarName = new HashMap<>();
        classLoaderFactoryName.put(
                "JDBC-MYSQL",
                "org.apache.seatunnel.datasource.plugin.mysql.jdbc.MysqlJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "ELASTICSEARCH",
                "org.apache.seatunnel.datasource.plugin.elasticsearch.ElasticSearchDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-CLICKHOUSE",
                "org.apache.seatunnel.datasource.plugin.clickhouse.jdbc.ClickhouseJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "HIVE", "org.apache.seatunnel.datasource.plugin.hive.HiveDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-ORACLE",
                "org.apache.seatunnel.datasource.plugin.oracle.jdbc.OracleJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-POSTGRES",
                "org.apache.seatunnel.datasource.plugin.postgresql.jdbc.PostgresqlDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-REDSHIFT",
                "org.apache.seatunnel.datasource.plugin.redshift.jdbc.RedshiftDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-SQLSERVER",
                "org.apache.seatunnel.datasource.plugin.sqlserver.jdbc.SqlServerDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-TIDB",
                "org.apache.seatunnel.datasource.plugin.tidb.jdbc.TidbJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-HIVE",
                "org.apache.seatunnel.datasource.plugin.hive.jdbc.HiveJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "KAFKA", "org.apache.seatunnel.datasource.plugin.kafka.KafkaDataSourceFactory");
        classLoaderFactoryName.put(
                "MYSQL-CDC",
                "org.apache.seatunnel.datasource.plugin.cdc.mysql.MysqlCDCDataSourceFactory");
        classLoaderFactoryName.put(
                "S3", "org.apache.seatunnel.datasource.plugin.s3.S3DataSourceFactory");
        classLoaderFactoryName.put(
                "S3-REDSHIFT",
                "org.apache.seatunnel.datasource.plugin.redshift.s3.S3RedshiftDataSourceFactory");
        classLoaderFactoryName.put(
                "SQLSERVER-CDC",
                "org.apache.seatunnel.datasource.plugin.cdc.sqlserver.SqlServerCDCDataSourceFactory");
        classLoaderFactoryName.put(
                "STARROCKS",
                "org.apache.seatunnel.datasource.plugin.starrocks.StarRocksDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-STARROCKS",
                "org.apache.seatunnel.datasource.plugin.starrocks.jdbc.StarRocksJdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "MONGODB", "com.apache.seatunnel.datasource.plugin.mongodb.MongoDataSourceFactory");
        classLoaderFactoryName.put(
                "JDBC-DB2",
                "org.apache.seatunnel.datasource.plugin.db2.jdbc.Db2JdbcDataSourceFactory");
        classLoaderFactoryName.put(
                "FAKESOURCE",
                "org.apache.seatunnel.datasource.plugin.fakesource.FakeSourceDataSourceFactory");
        classLoaderFactoryName.put(
                "CONSOLE",
                "org.apache.seatunnel.datasource.plugin.console.ConsoleDataSourceFactory");

        classLoaderJarName.put("JDBC-ORACLE", "datasource-jdbc-oracle-");
        classLoaderJarName.put("JDBC-CLICKHOUSE", "datasource-jdbc-clickhouse-");
        classLoaderJarName.put("JDBC-POSTGRES", "datasource-jdbc-postgresql-");
        classLoaderJarName.put("JDBC-TIDB", "datasource-jdbc-tidb-");
        classLoaderJarName.put("JDBC-REDSHIFT", "datasource-jdbc-redshift-");
        classLoaderJarName.put("JDBC-MYSQL", "datasource-jdbc-mysql-");
        classLoaderJarName.put("JDBC-SQLSERVER", "datasource-jdbc-sqlserver-");

        classLoaderJarName.put("SQLSERVER-CDC", "datasource-sqlserver-cdc-");
        classLoaderJarName.put("MYSQL-CDC", "datasource-mysql-cdc-");

        classLoaderJarName.put("ELASTICSEARCH", "datasource-elasticsearch-");
        classLoaderJarName.put("S3", "datasource-s3-");
        classLoaderJarName.put("HIVE", "datasource-hive-");
        classLoaderJarName.put("KAFKA", "datasource-kafka-");
        classLoaderJarName.put("STARROCKS", "datasource-starrocks-");
        classLoaderJarName.put("S3-REDSHIFT", "datasource-s3redshift-");
        classLoaderJarName.put("JDBC-STARROCKS", "datasource-jdbc-starrocks-");
        classLoaderJarName.put("MONGODB", "datasource-mongodb-");
        classLoaderJarName.put("JDBC-DB2", "datasource-jdbc-db2-");
        classLoaderJarName.put("JDBC-HIVE", "datasource-jdbc-hive-");
        classLoaderJarName.put("FAKESOURCE", "datasource-fakesource-");
        classLoaderJarName.put("CONSOLE", "datasource-console-");
    }