diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java index 951d4cdd8..1d3180fe9 100644 --- a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java +++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java @@ -78,9 +78,12 @@ public enum SeaTunnelPluginMapping { SOURCE_KAFKA(SEATUNNEL, SOURCE, KAFKA, "connector-kafka", GA, BATCH, STREAM, EXACTLY_ONCE, PARALLELISM), SINK_KAFKA(SEATUNNEL, SINK, KAFKA, "connector-kafka", GA, EXACTLY_ONCE), SOURCE_PULSAR(SEATUNNEL, SOURCE, PULSAR, "connector-pulsar", BETA, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), + SINK_PULSAR(SEATUNNEL, SINK, PULSAR, "connector-pulsar", BETA, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), SOURCE_ROCKETMQ(SEATUNNEL, SOURCE, ROCKETMQ, "connector-rocketmq", UNKNOWN, BATCH, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION), SINK_ROCKETMQ(SEATUNNEL, SINK, ROCKETMQ, "connector-rocketmq", UNKNOWN, EXACTLY_ONCE), SINK_DATAHUB(SEATUNNEL, SINK, DATAHUB, "connector-datahub", ALPHA), + SOURCE_AMAZON_SQS(SEATUNNEL, SOURCE, AMAZON_SQS, "connector-amazonsqs", UNKNOWN), + SINK_AMAZON_SQS(SEATUNNEL, SINK, AMAZON_SQS, "connector-amazonsqs", UNKNOWN), SOURCE_RABBITMQ(SEATUNNEL, SOURCE, RABBITMQ, "connector-rabbitmq", BETA, STREAM, EXACTLY_ONCE, COLUMN_PROJECTION), SINK_RABBITMQ(SEATUNNEL, SINK, RABBITMQ, "connector-rabbitmq", BETA), @@ -101,6 +104,7 @@ public enum SeaTunnelPluginMapping { SOURCE_MYSQL_CDC(SEATUNNEL, SOURCE, MYSQL_CDC, "connector-cdc-mysql", GA, STREAM, EXACTLY_ONCE, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), SOURCE_SQLSERVER_CDC(SEATUNNEL, SOURCE, SQLSERVER_CDC, "connector-cdc-sqlserver", GA, STREAM, EXACTLY_ONCE, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), + SOURCE_ORACLE_CDC(SEATUNNEL, SOURCE, ORACLE_CDC, "connector-cdc-oracle", UNKNOWN), SOURCE_MONGODB_CDC(SEATUNNEL, SOURCE, MONGODB_CDC, "connector-cdc-mongodb", UNKNOWN, STREAM, EXACTLY_ONCE, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), SOURCE_HIVE(SEATUNNEL, SOURCE, HIVE, "connector-hive", GA, BATCH, EXACTLY_ONCE, COLUMN_PROJECTION, PARALLELISM), @@ -108,6 +112,7 @@ public enum SeaTunnelPluginMapping { SOURCE_CLICKHOUSE(SEATUNNEL, SOURCE, CLICKHOUSE, "connector-clickhouse", GA, BATCH, COLUMN_PROJECTION), SINK_CLICKHOUSE(SEATUNNEL, SINK, CLICKHOUSE, "connector-clickhouse", GA, CDC), SINK_CLICKHOUSE_FILE(SEATUNNEL, SINK, CLICKHOUSE_FILE, "connector-clickhouse", GA), + SOURCE_DORIS(SEATUNNEL, SOURCE, DORIS, "connector-doris", BETA, EXACTLY_ONCE, CDC), SINK_DORIS(SEATUNNEL, SINK, DORIS, "connector-doris", BETA, EXACTLY_ONCE, CDC), SINK_SELECTDB_CLOUD(SEATUNNEL, SINK, SELECTDB_CLOUD, "connector-selectdb-cloud", BETA), SOURCE_STARROCKS(SEATUNNEL, SOURCE, STARROCKS, "connector-starrocks", UNKNOWN, BATCH, COLUMN_PROJECTION, PARALLELISM, SUPPORT_USER_DEFINED_SPLIT), diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java index bab4710bd..505c513af 100644 --- a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java +++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginName.java @@ -61,6 +61,7 @@ public enum SeaTunnelPluginName implements DictInstance { PULSAR("Pulsar", "Pulsar"), ROCKETMQ("Rocketmq", "RocketMQ"), DATAHUB("DataHub", "DataHub"), + AMAZON_SQS("AmazonSqs", "AmazonSQS"), RABBITMQ("RabbitMQ", "RabbitMQ"), JDBC("Jdbc", "Jdbc"), @@ -74,6 +75,7 @@ public enum SeaTunnelPluginName implements DictInstance { MYSQL_CDC("MySQL-CDC", "MySQL-CDC"), SQLSERVER_CDC("SqlServer-CDC", "SqlServer-CDC"), + ORACLE_CDC("Oracle-CDC", "Oracle-CDC"), MONGODB_CDC("MongoDB-CDC", "MongoDB-CDC"), HIVE("Hive", "Hive"),