You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/03/09 11:39:20 UTC
[incubator-seatunnel] branch dev updated: [Feature][connectors & transforms] refactor code module，split Flink and Spark. (#1398)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 74048e3 [Feature][connectors & transforms] refactor code module，split Flink and Spark. (#1398)
74048e3 is described below
commit 74048e357208ee7189856a82a206500394e72eea
Author: Zonglei Dong <do...@apache.org>
AuthorDate: Wed Mar 9 19:39:10 2022 +0800
[Feature][connectors & transforms] refactor code module，split Flink and Spark. (#1398)
* [Feature][connectors & transforms] refactor code module，split Flink and Spark.
---
seatunnel-connectors/pom.xml | 32 ++--------------------
.../seatunnel-connectors-flink}/pom.xml | 21 ++++++++------
.../seatunnel-connector-flink-console/pom.xml | 2 +-
.../apache/seatunnel/flink/sink/ConsoleSink.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../seatunnel-connector-flink-doris/pom.xml | 2 +-
.../seatunnel/flink/sink/DorisOutputFormat.java | 0
.../org/apache/seatunnel/flink/sink/DorisSink.java | 0
.../seatunnel/flink/sink/DorisSinkFunction.java | 0
.../seatunnel/flink/sink/DorisStreamLoad.java | 0
.../apache/seatunnel/flink/sink/RespContent.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../seatunnel-connector-flink-druid/pom.xml | 2 +-
.../seatunnel/flink/sink/DruidOutputFormat.java | 0
.../org/apache/seatunnel/flink/sink/DruidSink.java | 0
.../seatunnel/flink/source/DruidInputFormat.java | 0
.../apache/seatunnel/flink/source/DruidSource.java | 0
.../apache/seatunnel/flink/source/DruidSql.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../pom.xml | 2 +-
.../apache/seatunnel/flink/sink/Elasticsearch.java | 0
.../flink/sink/ElasticsearchOutputFormat.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../seatunnel-connector-flink-fake/pom.xml | 2 +-
.../seatunnel/flink/source/FakeSourceStream.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../seatunnel-connector-flink-file/pom.xml | 2 +-
.../seatunnel/flink/sink/CsvRowOutputFormat.java | 0
.../org/apache/seatunnel/flink/sink/FileSink.java | 0
.../seatunnel/flink/sink/JsonRowOutputFormat.java | 0
.../apache/seatunnel/flink/source/FileSource.java | 0
.../seatunnel/flink/source/JsonRowInputFormat.java | 0
.../seatunnel/flink/source/TextRowInputFormat.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../seatunnel-connector-flink-influxdb/pom.xml | 2 +-
.../seatunnel/flink/sink/InfluxDbOutputFormat.java | 0
.../apache/seatunnel/flink/sink/InfluxDbSink.java | 0
.../flink/source/InfluxDbInputFormat.java | 0
.../seatunnel/flink/source/InfluxDbSource.java | 0
.../apache/seatunnel/flink/source/InfluxDbSql.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../seatunnel-connector-flink-jdbc/pom.xml | 2 +-
.../org/apache/seatunnel/flink/sink/JdbcSink.java | 0
.../apache/seatunnel/flink/source/JdbcSource.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../seatunnel-connector-flink-kafka/pom.xml | 2 +-
.../apache/seatunnel/flink/sink/KafkaTable.java | 0
.../seatunnel/flink/source/KafkaTableStream.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSink | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../seatunnel-connector-flink-socket/pom.xml | 2 +-
.../seatunnel/flink/source/SocketStream.java | 0
.../org.apache.seatunnel.flink.BaseFlinkSource | 0
.../{ => seatunnel-connectors-spark}/pom.xml | 14 ++--------
.../seatunnel-connector-spark-clickhouse/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../apache/seatunnel/spark/sink/Clickhouse.scala | 0
.../seatunnel-connector-spark-console/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org/apache/seatunnel/spark/sink/Console.scala | 0
.../seatunnel-connector-spark-doris/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org/apache/seatunnel/spark/sink/Config.scala | 0
.../org/apache/seatunnel/spark/sink/Doris.scala | 0
.../apache/seatunnel/spark/sink/DorisUtil.scala | 0
.../pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../seatunnel/spark/sink/Elasticsearch.scala | 0
.../seatunnel/spark/source/Elasticsearch.scala | 0
.../seatunnel-connector-spark-email/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../apache/seatunnel/spark/sink/DataLocator.scala | 0
.../org/apache/seatunnel/spark/sink/Email.scala | 0
.../seatunnel/spark/sink/ExcelFileSaver.scala | 0
.../org/apache/seatunnel/spark/sink/Util.scala | 0
.../seatunnel-connector-spark-fake/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/source/Fake.scala | 0
.../apache/seatunnel/spark/source/FakeStream.scala | 0
.../seatunnel-connector-spark-file/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../scala/org/apache/seatunnel/spark/Config.scala | 0
.../org/apache/seatunnel/spark/sink/File.scala | 0
.../org/apache/seatunnel/spark/source/File.scala | 0
.../seatunnel-connector-spark-hbase/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Hbase.scala | 0
.../seatunnel/spark/sink/HbaseSaveMode.scala | 0
.../org/apache/seatunnel/spark/source/Hbase.scala | 0
.../seatunnel-connector-spark-hive/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Hive.scala | 0
.../org/apache/seatunnel/spark/source/Hive.scala | 0
.../seatunnel-connector-spark-hudi/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Hudi.scala | 0
.../org/apache/seatunnel/spark/source/Hudi.scala | 0
.../seatunnel-connector-spark-iceberg/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../apache/seatunnel/spark/source/Iceberg.scala | 0
.../seatunnel-connector-spark-jdbc/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Jdbc.scala | 0
.../org/apache/seatunnel/spark/source/Jdbc.scala | 0
.../datasources/jdbc2/DefaultSource.scala | 0
.../execution/datasources/jdbc2/JDBCOptions.scala | 0
.../datasources/jdbc2/JDBCPartition.scala | 0
.../datasources/jdbc2/JDBCPartitioningInfo.scala | 0
.../execution/datasources/jdbc2/JDBCSaveMode.scala | 0
.../execution/datasources/jdbc2/JdbcUtils.scala | 0
.../seatunnel-connector-spark-kafka/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Kafka.scala | 0
.../seatunnel/spark/sink/KafkaProducerUtil.scala | 0
.../seatunnel/spark/source/KafkaStream.scala | 0
.../seatunnel-connector-spark-kudu/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Kudu.scala | 0
.../org/apache/seatunnel/spark/source/Kudu.scala | 0
.../seatunnel-connector-spark-mongodb/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/MongoDB.scala | 0
.../apache/seatunnel/spark/source/MongoDB.scala | 0
.../seatunnel-connector-spark-neo4j/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/source/Neo4j.scala | 0
.../seatunnel-connector-spark-phoenix/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../scala/org/apache/phoenix/spark/CsUtil.scala | 0
.../apache/phoenix/spark/DataFrameFunctions2.scala | 0
.../org/apache/phoenix/spark/PhoenixRDD2.scala | 0
.../phoenix/spark/SparkSqlContextFunctions2.scala | 0
.../org/apache/phoenix/spark/ZkConnectUtil.scala | 0
.../org/apache/phoenix/spark/sparkExtend.scala | 0
.../org/apache/seatunnel/spark/sink/Phoenix.scala | 0
.../apache/seatunnel/spark/source/Phoenix.scala | 0
.../seatunnel-connector-spark-redis/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../apache/seatunnel/spark/common/Constants.scala | 0
.../seatunnel/spark/common/RedisDataType.scala | 0
.../org/apache/seatunnel/spark/sink/Redis.scala | 0
.../org/apache/seatunnel/spark/source/Redis.scala | 0
.../seatunnel-connector-spark-socket/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../seatunnel/spark/source/SocketStream.scala | 0
.../seatunnel-connector-spark-tidb/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkSink | 0
.../org.apache.seatunnel.spark.BaseSparkSource | 0
.../org/apache/seatunnel/spark/sink/Tidb.scala | 0
.../org/apache/seatunnel/spark/source/Tidb.scala | 0
seatunnel-transforms/pom.xml | 9 ++----
.../{ => seatunnel-transforms-flink}/pom.xml | 7 ++---
.../pom.xml | 2 +-
.../flink/transform/DataStreamToTable.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../seatunnel-transform-flink-split/pom.xml | 2 +-
.../seatunnel/flink/transform/ScalarSplit.java | 0
.../apache/seatunnel/flink/transform/Split.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../seatunnel-transform-flink-sql/pom.xml | 2 +-
.../org/apache/seatunnel/flink/transform/Sql.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../pom.xml | 2 +-
.../flink/transform/TableToDataStream.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../{ => seatunnel-transforms-spark}/pom.xml | 8 ++----
.../seatunnel-transform-spark-json/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../apache/seatunnel/spark/transform/Json.scala | 0
.../seatunnel-transform-spark-split/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../apache/seatunnel/spark/transform/Split.scala | 0
.../seatunnel-transform-spark-sql/pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../org/apache/seatunnel/spark/transform/Sql.scala | 0
190 files changed, 59 insertions(+), 106 deletions(-)
diff --git a/seatunnel-connectors/pom.xml b/seatunnel-connectors/pom.xml
index c083f5d..43988c9 100644
--- a/seatunnel-connectors/pom.xml
+++ b/seatunnel-connectors/pom.xml
@@ -31,36 +31,8 @@
<packaging>pom</packaging>
<modules>
- <module>seatunnel-connector-spark-doris</module>
- <module>seatunnel-connector-spark-file</module>
- <module>seatunnel-connector-spark-kafka</module>
- <module>seatunnel-connector-spark-socket</module>
- <module>seatunnel-connector-spark-redis</module>
- <module>seatunnel-connector-spark-phoenix</module>
- <module>seatunnel-connector-spark-mongodb</module>
- <module>seatunnel-connector-spark-kudu</module>
- <module>seatunnel-connector-spark-jdbc</module>
- <module>seatunnel-connector-spark-hive</module>
- <module>seatunnel-connector-spark-fake</module>
- <module>seatunnel-connector-spark-elasticsearch</module>
- <module>seatunnel-connector-spark-hudi</module>
- <module>seatunnel-connector-spark-hbase</module>
- <module>seatunnel-connector-spark-console</module>
- <module>seatunnel-connector-spark-clickhouse</module>
- <module>seatunnel-connector-spark-email</module>
- <module>seatunnel-connector-spark-tidb</module>
- <module>seatunnel-connector-spark-neo4j</module>
- <module>seatunnel-connector-spark-iceberg</module>
- <module>seatunnel-connector-flink-console</module>
- <module>seatunnel-connector-flink-druid</module>
- <module>seatunnel-connector-flink-elasticsearch</module>
- <module>seatunnel-connector-flink-file</module>
- <module>seatunnel-connector-flink-jdbc</module>
- <module>seatunnel-connector-flink-kafka</module>
- <module>seatunnel-connector-flink-fake</module>
- <module>seatunnel-connector-flink-socket</module>
- <module>seatunnel-connector-flink-doris</module>
- <module>seatunnel-connector-flink-influxdb</module>
+ <module>seatunnel-connectors-flink</module>
+ <module>seatunnel-connectors-spark</module>
</modules>
</project>
diff --git a/seatunnel-transforms/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/pom.xml
similarity index 65%
copy from seatunnel-transforms/pom.xml
copy to seatunnel-connectors/seatunnel-connectors-flink/pom.xml
index 2d1a6b6..f14c695 100644
--- a/seatunnel-transforms/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/pom.xml
@@ -22,22 +22,25 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel</artifactId>
+ <artifactId>seatunnel-connectors</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<packaging>pom</packaging>
<modules>
- <module>seatunnel-transform-flink-table2datastream</module>
- <module>seatunnel-transform-flink-datastream2table</module>
- <module>seatunnel-transform-flink-sql</module>
- <module>seatunnel-transform-flink-split</module>
- <module>seatunnel-transform-spark-json</module>
- <module>seatunnel-transform-spark-split</module>
- <module>seatunnel-transform-spark-sql</module>
+ <module>seatunnel-connector-flink-console</module>
+ <module>seatunnel-connector-flink-druid</module>
+ <module>seatunnel-connector-flink-elasticsearch</module>
+ <module>seatunnel-connector-flink-file</module>
+ <module>seatunnel-connector-flink-jdbc</module>
+ <module>seatunnel-connector-flink-kafka</module>
+ <module>seatunnel-connector-flink-fake</module>
+ <module>seatunnel-connector-flink-socket</module>
+ <module>seatunnel-connector-flink-doris</module>
+ <module>seatunnel-connector-flink-influxdb</module>
</modules>
</project>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-console/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-console/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/pom.xml
index 8ab63ae..79ac972 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-console/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/java/org/apache/seatunnel/flink/sink/ConsoleSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-console/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-console/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-console/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/pom.xml
index c64eb98..1e073f3 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-doris/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSinkFunction.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisStreamLoad.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/RespContent.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/RespContent.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/RespContent.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/RespContent.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-doris/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/pom.xml
index 9d390e5..28c11f9 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-druid/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/sink/DruidSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidInputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSource.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/java/org/apache/seatunnel/flink/source/DruidSql.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-druid/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-flink-elasticsearch/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/pom.xml
index 474ec9a..bf38d4c 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/Elasticsearch.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/java/org/apache/seatunnel/flink/sink/ElasticsearchOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-fake/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-fake/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/pom.xml
index 2a5a225..f89d109 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-fake/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/java/org/apache/seatunnel/flink/source/FakeSourceStream.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-fake/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-fake/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-fake/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-flink-file/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/pom.xml
index ed6a1ef..1781134 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-file/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/CsvRowOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/FileSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/JsonRowOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/JsonRowOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/JsonRowOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/sink/JsonRowOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/FileSource.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/JsonRowInputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/java/org/apache/seatunnel/flink/source/TextRowInputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/pom.xml
index 92a46aa..53db758 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-influxdb/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbOutputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/sink/InfluxDbSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbInputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbInputFormat.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbInputFormat.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbInputFormat.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSource.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSource.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSource.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSource.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSql.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSql.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSql.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/java/org/apache/seatunnel/flink/source/InfluxDbSql.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-influxdb/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/pom.xml
index bef60e0..b504774 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-kafka/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/pom.xml
index 60c5d1c..8b502d2 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-kafka/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSink
diff --git a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/seatunnel-connector-flink-socket/pom.xml b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-flink-socket/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/pom.xml
index 7b54b4a..7ae7553 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-socket/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/java/org/apache/seatunnel/flink/source/SocketStream.java
diff --git a/seatunnel-connectors/seatunnel-connector-flink-socket/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-flink-socket/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
rename to seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-socket/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkSource
diff --git a/seatunnel-connectors/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/pom.xml
similarity index 78%
copy from seatunnel-connectors/pom.xml
copy to seatunnel-connectors/seatunnel-connectors-spark/pom.xml
index c083f5d..80306a0 100644
--- a/seatunnel-connectors/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/pom.xml
@@ -22,12 +22,12 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel</artifactId>
+ <artifactId>seatunnel-connectors</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<packaging>pom</packaging>
<modules>
@@ -51,16 +51,6 @@
<module>seatunnel-connector-spark-tidb</module>
<module>seatunnel-connector-spark-neo4j</module>
<module>seatunnel-connector-spark-iceberg</module>
- <module>seatunnel-connector-flink-console</module>
- <module>seatunnel-connector-flink-druid</module>
- <module>seatunnel-connector-flink-elasticsearch</module>
- <module>seatunnel-connector-flink-file</module>
- <module>seatunnel-connector-flink-jdbc</module>
- <module>seatunnel-connector-flink-kafka</module>
- <module>seatunnel-connector-flink-fake</module>
- <module>seatunnel-connector-flink-socket</module>
- <module>seatunnel-connector-flink-doris</module>
- <module>seatunnel-connector-flink-influxdb</module>
</modules>
</project>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-clickhouse/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-clickhouse/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
index d45b771..cf2281d 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-clickhouse/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/sink/Clickhouse.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/sink/Clickhouse.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/sink/Clickhouse.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-clickhouse/src/main/scala/org/apache/seatunnel/spark/sink/Clickhouse.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-console/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-console/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/pom.xml
index 3a42dd9..c25da60 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-console/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/sink/Console.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/sink/Console.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/sink/Console.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-console/src/main/scala/org/apache/seatunnel/spark/sink/Console.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-spark-doris/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/pom.xml
index 0d24830..8711213 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-doris/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Config.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/Doris.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/DorisUtil.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/DorisUtil.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/DorisUtil.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/scala/org/apache/seatunnel/spark/sink/DorisUtil.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-elasticsearch/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
index 856b9e4..ffff2aa 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/sink/Elasticsearch.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/sink/Elasticsearch.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/sink/Elasticsearch.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/sink/Elasticsearch.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/source/Elasticsearch.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/source/Elasticsearch.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/source/Elasticsearch.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-elasticsearch/src/main/scala/org/apache/seatunnel/spark/source/Elasticsearch.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-email/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
index 5e93e1a..fb9c920 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-email/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/DataLocator.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/DataLocator.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/DataLocator.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/DataLocator.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Email.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Email.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Email.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Email.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/ExcelFileSaver.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/ExcelFileSaver.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/ExcelFileSaver.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/ExcelFileSaver.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Util.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Util.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Util.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-email/src/main/scala/org/apache/seatunnel/spark/sink/Util.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-fake/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-fake/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/pom.xml
index 1948516..ddd9989 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-fake/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/Fake.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/Fake.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/Fake.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/Fake.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/FakeStream.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/FakeStream.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/FakeStream.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-fake/src/main/scala/org/apache/seatunnel/spark/source/FakeStream.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-file/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/pom.xml
index fc67448..15b9904 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-file/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/Config.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/Config.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/Config.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/Config.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/sink/File.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/sink/File.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/sink/File.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/sink/File.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/source/File.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/source/File.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/source/File.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-file/src/main/scala/org/apache/seatunnel/spark/source/File.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
index 18a6f31..f51dd8e 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-hbase/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/Hbase.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/Hbase.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/Hbase.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/Hbase.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/HbaseSaveMode.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/HbaseSaveMode.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/HbaseSaveMode.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/sink/HbaseSaveMode.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/source/Hbase.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/source/Hbase.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/source/Hbase.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hbase/src/main/scala/org/apache/seatunnel/spark/source/Hbase.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-hive/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/pom.xml
index 76bf66b..b46c53a 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-hive/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/sink/Hive.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/source/Hive.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/source/Hive.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/source/Hive.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hive/src/main/scala/org/apache/seatunnel/spark/source/Hive.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hudi/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-hudi/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/pom.xml
index 802a173..2a4e7d3 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-hudi/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/sink/Hudi.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/sink/Hudi.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/sink/Hudi.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/sink/Hudi.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/source/Hudi.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/source/Hudi.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/source/Hudi.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/source/Hudi.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-iceberg/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-iceberg/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/pom.xml
index 5b15df0..cb18531 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-iceberg/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/pom.xml
@@ -21,8 +21,8 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
- <artifactId>seatunnel-connectors</artifactId>
<groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/source/Iceberg.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/source/Iceberg.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/source/Iceberg.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-iceberg/src/main/scala/org/apache/seatunnel/spark/source/Iceberg.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/pom.xml
index f76a6a6..f8997b0 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-jdbc/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/sink/Jdbc.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/sink/Jdbc.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/sink/Jdbc.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/sink/Jdbc.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/source/Jdbc.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/source/Jdbc.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/source/Jdbc.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/seatunnel/spark/source/Jdbc.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/DefaultSource.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCOptions.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartition.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCPartitioningInfo.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JDBCSaveMode.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/pom.xml
index cbb4750..f6c5cd7 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-kafka/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/Kafka.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/Kafka.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/Kafka.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/Kafka.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/KafkaProducerUtil.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/KafkaProducerUtil.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/KafkaProducerUtil.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/sink/KafkaProducerUtil.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/source/KafkaStream.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/source/KafkaStream.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/source/KafkaStream.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kafka/src/main/scala/org/apache/seatunnel/spark/source/KafkaStream.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kudu/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-kudu/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/pom.xml
index d292aa1..83e41c0 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-kudu/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/sink/Kudu.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/sink/Kudu.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/sink/Kudu.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/sink/Kudu.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/source/Kudu.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/source/Kudu.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/source/Kudu.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-kudu/src/main/scala/org/apache/seatunnel/spark/source/Kudu.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-mongodb/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
index 4e7769c..1e04e09 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-mongodb/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/pom.xml
@@ -18,7 +18,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/sink/MongoDB.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/sink/MongoDB.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/sink/MongoDB.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/sink/MongoDB.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-mongodb/src/main/scala/org/apache/seatunnel/spark/source/MongoDB.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-neo4j/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-spark-neo4j/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/pom.xml
index 3965cc6..0b3df7a 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-neo4j/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/pom.xml
@@ -21,8 +21,8 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
- <artifactId>seatunnel-connectors</artifactId>
<groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/source/Neo4j.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/source/Neo4j.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/source/Neo4j.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-neo4j/src/main/scala/org/apache/seatunnel/spark/source/Neo4j.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
index 1e70b31..c6cd464 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-phoenix/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/CsUtil.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/DataFrameFunctions2.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/PhoenixRDD2.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/SparkSqlContextFunctions2.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/ZkConnectUtil.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/phoenix/spark/sparkExtend.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/sink/Phoenix.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/sink/Phoenix.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/sink/Phoenix.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/sink/Phoenix.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/source/Phoenix.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/source/Phoenix.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/source/Phoenix.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-phoenix/src/main/scala/org/apache/seatunnel/spark/source/Phoenix.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/pom.xml
index e55bc4f..8ea183a 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-redis/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/Constants.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/Constants.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/Constants.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/Constants.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/RedisDataType.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/RedisDataType.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/RedisDataType.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/common/RedisDataType.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/sink/Redis.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/sink/Redis.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/sink/Redis.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/sink/Redis.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/source/Redis.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/source/Redis.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/source/Redis.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-redis/src/main/scala/org/apache/seatunnel/spark/source/Redis.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-socket/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/pom.xml
similarity index 96%
rename from seatunnel-connectors/seatunnel-connector-spark-socket/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/pom.xml
index bc6d03c..bfb01c8 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-socket/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-connectors</artifactId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/source/SocketStream.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/source/SocketStream.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/source/SocketStream.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-socket/src/main/scala/org/apache/seatunnel/spark/source/SocketStream.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-tidb/pom.xml b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/pom.xml
similarity index 97%
rename from seatunnel-connectors/seatunnel-connector-spark-tidb/pom.xml
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/pom.xml
index f2f678c..38d9687 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-tidb/pom.xml
+++ b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/pom.xml
@@ -21,8 +21,8 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
- <artifactId>seatunnel-connectors</artifactId>
<groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-connectors-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
diff --git a/seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSource
diff --git a/seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/sink/Tidb.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/sink/Tidb.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/sink/Tidb.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/sink/Tidb.scala
diff --git a/seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/source/Tidb.scala b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/source/Tidb.scala
similarity index 100%
rename from seatunnel-connectors/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/source/Tidb.scala
rename to seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-tidb/src/main/scala/org/apache/seatunnel/spark/source/Tidb.scala
diff --git a/seatunnel-transforms/pom.xml b/seatunnel-transforms/pom.xml
index 2d1a6b6..d80c656 100644
--- a/seatunnel-transforms/pom.xml
+++ b/seatunnel-transforms/pom.xml
@@ -31,13 +31,8 @@
<packaging>pom</packaging>
<modules>
- <module>seatunnel-transform-flink-table2datastream</module>
- <module>seatunnel-transform-flink-datastream2table</module>
- <module>seatunnel-transform-flink-sql</module>
- <module>seatunnel-transform-flink-split</module>
- <module>seatunnel-transform-spark-json</module>
- <module>seatunnel-transform-spark-split</module>
- <module>seatunnel-transform-spark-sql</module>
+ <module>seatunnel-transforms-flink</module>
+ <module>seatunnel-transforms-spark</module>
</modules>
</project>
diff --git a/seatunnel-transforms/pom.xml b/seatunnel-transforms/seatunnel-transforms-flink/pom.xml
similarity index 85%
copy from seatunnel-transforms/pom.xml
copy to seatunnel-transforms/seatunnel-transforms-flink/pom.xml
index 2d1a6b6..7fec044 100644
--- a/seatunnel-transforms/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-flink/pom.xml
@@ -22,12 +22,12 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel</artifactId>
+ <artifactId>seatunnel-transforms</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-flink</artifactId>
<packaging>pom</packaging>
<modules>
@@ -35,9 +35,6 @@
<module>seatunnel-transform-flink-datastream2table</module>
<module>seatunnel-transform-flink-sql</module>
<module>seatunnel-transform-flink-split</module>
- <module>seatunnel-transform-spark-json</module>
- <module>seatunnel-transform-spark-split</module>
- <module>seatunnel-transform-spark-sql</module>
</modules>
</project>
diff --git a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/pom.xml
similarity index 97%
rename from seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/pom.xml
index 83c7bd4..c1c9b13 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
diff --git a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-flink-split/pom.xml b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/pom.xml
similarity index 97%
rename from seatunnel-transforms/seatunnel-transform-flink-split/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/pom.xml
index 9cb2ed9..9f016c2 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-split/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
diff --git a/seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
diff --git a/seatunnel-transforms/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/pom.xml
similarity index 97%
rename from seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/pom.xml
index 5c13f61..5e85fca 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
diff --git a/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/pom.xml
similarity index 97%
rename from seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/pom.xml
index ec76e34..f2063c8 100644
--- a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-flink</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
diff --git a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/pom.xml b/seatunnel-transforms/seatunnel-transforms-spark/pom.xml
similarity index 81%
copy from seatunnel-transforms/pom.xml
copy to seatunnel-transforms/seatunnel-transforms-spark/pom.xml
index 2d1a6b6..ccc1f16 100644
--- a/seatunnel-transforms/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-spark/pom.xml
@@ -22,19 +22,15 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel</artifactId>
+ <artifactId>seatunnel-transforms</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-spark</artifactId>
<packaging>pom</packaging>
<modules>
- <module>seatunnel-transform-flink-table2datastream</module>
- <module>seatunnel-transform-flink-datastream2table</module>
- <module>seatunnel-transform-flink-sql</module>
- <module>seatunnel-transform-flink-split</module>
<module>seatunnel-transform-spark-json</module>
<module>seatunnel-transform-spark-split</module>
<module>seatunnel-transform-spark-sql</module>
diff --git a/seatunnel-transforms/seatunnel-transform-spark-json/pom.xml b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/pom.xml
similarity index 96%
rename from seatunnel-transforms/seatunnel-transform-spark-json/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/pom.xml
index 5ab8232..34398de 100644
--- a/seatunnel-transforms/seatunnel-transform-spark-json/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
diff --git a/seatunnel-transforms/seatunnel-transform-spark-split/pom.xml b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/pom.xml
similarity index 96%
rename from seatunnel-transforms/seatunnel-transform-spark-split/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/pom.xml
index 9bed6cd..71a1517 100644
--- a/seatunnel-transforms/seatunnel-transform-spark-split/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
diff --git a/seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/pom.xml
similarity index 96%
rename from seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/pom.xml
index 3b9bcb2..88d61a2 100644
--- a/seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml
+++ b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/pom.xml
@@ -22,7 +22,7 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>seatunnel-transforms</artifactId>
+ <artifactId>seatunnel-transforms-spark</artifactId>
<version>2.0.5-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/seatunnel-transforms/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala b/seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala
similarity index 100%
rename from seatunnel-transforms/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala
rename to seatunnel-transforms/seatunnel-transforms-spark/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala