feature: update seatunnel 2.3.4 connectors

flowerfine · Jan 17, 2024 · c572684 · c572684
1 parent 9c42a1f
commit c572684
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/...h-common/src/main/java/cn/sliew/scaleph/common/dict/seatunnel/SeaTunnelPluginMapping.java b/...h-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,13 +104,15 @@ 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),
     SINK_HIVE(SEATUNNEL, SINK, HIVE, "connector-hive", GA, EXACTLY_ONCE),
     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
@@ -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"),