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 2021/12/30 12:47:35 UTC
[incubator-seatunnel] branch dev updated: [Feature][seatunnel-transforms] refine transforms structure (#892)
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 c23fef9 [Feature][seatunnel-transforms] refine transforms structure (#892)
c23fef9 is described below
commit c23fef971276824650069c2d83a172434e9ed6a4
Author: zixi0825 <su...@gmail.com>
AuthorDate: Thu Dec 30 20:47:32 2021 +0800
[Feature][seatunnel-transforms] refine transforms structure (#892)
* refine transforms
* Update CheckResult.java
revert checkresult change
Co-authored-by: zixi0825 <su...@linklogis.com>
---
.../sql/execution/datasources/jdbc2/JdbcUtils.scala | 4 ++--
seatunnel-core/seatunnel-core-flink/pom.xml | 8 ++++----
seatunnel-core/seatunnel-core-spark/pom.xml | 16 ++++++++--------
.../org.apache.seatunnel.flink.BaseFlinkTransform | 1 -
seatunnel-transforms/pom.xml | 14 +++++++-------
.../pom.xml | 4 ++--
.../seatunnel/flink/transform/DataStreamToTable.java} | 2 +-
.../org.apache.seatunnel.flink.BaseFlinkTransform | 1 +
.../pom.xml | 2 +-
.../apache/seatunnel/flink/transform/ScalarSplit.java | 0
.../java/org/apache/seatunnel/flink/transform/Split.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../pom.xml | 2 +-
.../java/org/apache/seatunnel/flink/transform/Sql.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../pom.xml | 4 ++--
.../seatunnel/flink/transform/TableToDataStream.java | 0
.../org.apache.seatunnel.flink.BaseFlinkTransform | 0
.../pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../org/apache/seatunnel/spark/transform/Json.scala | 0
.../pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../org/apache/seatunnel/spark/transform/Split.scala | 0
.../pom.xml | 2 +-
.../org.apache.seatunnel.spark.BaseSparkTransform | 0
.../scala/org/apache/seatunnel/spark/transform/Sql.scala | 0
27 files changed, 32 insertions(+), 32 deletions(-)
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-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
index 665719a..bd0e37d 100644
--- a/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
+++ b/seatunnel-connectors/seatunnel-connector-spark-jdbc/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc2/JdbcUtils.scala
@@ -177,13 +177,13 @@ object JdbcUtils extends Logging {
else s"$name=VALUES($name)"
}
.mkString(",")
+ // scalastyle:off
val sql =
s"INSERT INTO $table ($columns) VALUES ($placeholders) ON DUPLICATE KEY UPDATE $duplicateSetting"
if (props.getProperty("showSql", "false").equals("true")) {
- // scalastyle:off
println(s"${JDBCSaveMode.Update} => sql => $sql")
- // scalastyle:on
}
+ // scalastyle:on
sql
case _ => s"INSERT INTO $table ($columns) VALUES ($placeholders)"
}
diff --git a/seatunnel-core/seatunnel-core-flink/pom.xml b/seatunnel-core/seatunnel-core-flink/pom.xml
index e583ca7..bbb819a 100644
--- a/seatunnel-core/seatunnel-core-flink/pom.xml
+++ b/seatunnel-core/seatunnel-core-flink/pom.xml
@@ -98,25 +98,25 @@
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-flink-transform-sql</artifactId>
+ <artifactId>seatunnel-transform-flink-sql</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-flink-transform-split</artifactId>
+ <artifactId>seatunnel-transform-flink-split</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-flink-transform-table2datasteam</artifactId>
+ <artifactId>seatunnel-transform-flink-table2datastream</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-flink-transform-datastream2table</artifactId>
+ <artifactId>seatunnel-transform-flink-datastream2table</artifactId>
<version>${project.version}</version>
</dependency>
diff --git a/seatunnel-core/seatunnel-core-spark/pom.xml b/seatunnel-core/seatunnel-core-spark/pom.xml
index e8a4e6e..eb40438 100644
--- a/seatunnel-core/seatunnel-core-spark/pom.xml
+++ b/seatunnel-core/seatunnel-core-spark/pom.xml
@@ -120,12 +120,6 @@
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-spark-transform-split</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <dependency>
- <groupId>org.apache.seatunnel</groupId>
<artifactId>seatunnel-connector-spark-console</artifactId>
<version>${project.version}</version>
</dependency>
@@ -156,13 +150,19 @@
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-spark-transform-sql</artifactId>
+ <artifactId>seatunnel-transform-spark-split</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>seatunnel-transform-spark-sql</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.seatunnel</groupId>
- <artifactId>plugin-spark-transform-json</artifactId>
+ <artifactId>seatunnel-transform-spark-json</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
diff --git a/seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
deleted file mode 100644
index af46b54..0000000
--- a/seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
+++ /dev/null
@@ -1 +0,0 @@
-org.apache.seatunnel.flink.transform.DataSteamToTable
\ No newline at end of file
diff --git a/seatunnel-transforms/pom.xml b/seatunnel-transforms/pom.xml
index cc71594..2d1a6b6 100644
--- a/seatunnel-transforms/pom.xml
+++ b/seatunnel-transforms/pom.xml
@@ -31,13 +31,13 @@
<packaging>pom</packaging>
<modules>
- <module>plugin-flink-transform-table2datasteam</module>
- <module>plugin-flink-transform-datastream2table</module>
- <module>plugin-spark-transform-sql</module>
- <module>plugin-flink-transform-sql</module>
- <module>plugin-flink-transform-split</module>
- <module>plugin-spark-transform-json</module>
- <module>plugin-spark-transform-split</module>
+ <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>
</modules>
</project>
diff --git a/seatunnel-transforms/plugin-flink-transform-table2datasteam/pom.xml b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml
similarity index 96%
rename from seatunnel-transforms/plugin-flink-transform-table2datasteam/pom.xml
rename to seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml
index c8a9172..83c7bd4 100644
--- a/seatunnel-transforms/plugin-flink-transform-table2datasteam/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-flink-transform-table2datasteam</artifactId>
+ <artifactId>seatunnel-transform-flink-datastream2table</artifactId>
<dependencies>
<dependency>
@@ -36,6 +36,7 @@
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
+
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
@@ -50,5 +51,4 @@
</dependency>
</dependencies>
-
</project>
diff --git a/seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataSteamToTable.java b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
similarity index 95%
rename from seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataSteamToTable.java
rename to seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
index f268088..2ee046b 100644
--- a/seatunnel-transforms/plugin-flink-transform-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataSteamToTable.java
+++ b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
@@ -30,7 +30,7 @@ import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
-public class DataSteamToTable implements FlinkStreamTransform<Row, Row>, FlinkBatchTransform<Row, Row> {
+public class DataStreamToTable implements FlinkStreamTransform<Row, Row>, FlinkBatchTransform<Row, Row> {
private Config config;
diff --git a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
new file mode 100644
index 0000000..172ca0c
--- /dev/null
+++ b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
@@ -0,0 +1 @@
+org.apache.seatunnel.flink.transform.DataStreamToTable
\ No newline at end of file
diff --git a/seatunnel-transforms/plugin-flink-transform-sql/pom.xml b/seatunnel-transforms/seatunnel-transform-flink-split/pom.xml
similarity index 97%
rename from seatunnel-transforms/plugin-flink-transform-sql/pom.xml
rename to seatunnel-transforms/seatunnel-transform-flink-split/pom.xml
index b8dab04..9cb2ed9 100644
--- a/seatunnel-transforms/plugin-flink-transform-sql/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-flink-split/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-flink-transform-sql</artifactId>
+ <artifactId>seatunnel-transform-flink-split</artifactId>
<dependencies>
<dependency>
diff --git a/seatunnel-transforms/plugin-flink-transform-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java b/seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
rename to seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/ScalarSplit.java
diff --git a/seatunnel-transforms/plugin-flink-transform-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java b/seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
rename to seatunnel-transforms/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
diff --git a/seatunnel-transforms/plugin-flink-transform-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transform-flink-split/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/plugin-flink-transform-split/pom.xml b/seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml
similarity index 97%
rename from seatunnel-transforms/plugin-flink-transform-split/pom.xml
rename to seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml
index 5dc1efb..5c13f61 100644
--- a/seatunnel-transforms/plugin-flink-transform-split/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-flink-sql/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-flink-transform-split</artifactId>
+ <artifactId>seatunnel-transform-flink-sql</artifactId>
<dependencies>
<dependency>
diff --git a/seatunnel-transforms/plugin-flink-transform-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java b/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
rename to seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
diff --git a/seatunnel-transforms/plugin-flink-transform-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transform-flink-sql/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/plugin-flink-transform-datastream2table/pom.xml b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml
similarity index 96%
rename from seatunnel-transforms/plugin-flink-transform-datastream2table/pom.xml
rename to seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml
index 1103c25..ec76e34 100644
--- a/seatunnel-transforms/plugin-flink-transform-datastream2table/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-flink-transform-datastream2table</artifactId>
+ <artifactId>seatunnel-transform-flink-table2datastream</artifactId>
<dependencies>
<dependency>
@@ -36,7 +36,6 @@
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
-
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
@@ -51,4 +50,5 @@
</dependency>
</dependencies>
+
</project>
diff --git a/seatunnel-transforms/plugin-flink-transform-table2datasteam/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-table2datasteam/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
rename to seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
diff --git a/seatunnel-transforms/plugin-flink-transform-table2datasteam/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-flink-transform-table2datasteam/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
rename to seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/resources/META-INF/services/org.apache.seatunnel.flink.BaseFlinkTransform
diff --git a/seatunnel-transforms/plugin-spark-transform-json/pom.xml b/seatunnel-transforms/seatunnel-transform-spark-json/pom.xml
similarity index 96%
rename from seatunnel-transforms/plugin-spark-transform-json/pom.xml
rename to seatunnel-transforms/seatunnel-transform-spark-json/pom.xml
index 173ef44..5ab8232 100644
--- a/seatunnel-transforms/plugin-spark-transform-json/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-spark-json/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-spark-transform-json</artifactId>
+ <artifactId>seatunnel-transform-spark-json</artifactId>
<dependencies>
<dependency>
diff --git a/seatunnel-transforms/plugin-spark-transform-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transform-spark-json/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/plugin-spark-transform-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala b/seatunnel-transforms/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
rename to seatunnel-transforms/seatunnel-transform-spark-json/src/main/scala/org/apache/seatunnel/spark/transform/Json.scala
diff --git a/seatunnel-transforms/plugin-spark-transform-split/pom.xml b/seatunnel-transforms/seatunnel-transform-spark-split/pom.xml
similarity index 96%
rename from seatunnel-transforms/plugin-spark-transform-split/pom.xml
rename to seatunnel-transforms/seatunnel-transform-spark-split/pom.xml
index ffcfb89..9bed6cd 100644
--- a/seatunnel-transforms/plugin-spark-transform-split/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-spark-split/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-spark-transform-split</artifactId>
+ <artifactId>seatunnel-transform-spark-split</artifactId>
<dependencies>
<dependency>
diff --git a/seatunnel-transforms/plugin-spark-transform-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transform-spark-split/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/plugin-spark-transform-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala b/seatunnel-transforms/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
rename to seatunnel-transforms/seatunnel-transform-spark-split/src/main/scala/org/apache/seatunnel/spark/transform/Split.scala
diff --git a/seatunnel-transforms/plugin-spark-transform-sql/pom.xml b/seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml
similarity index 96%
rename from seatunnel-transforms/plugin-spark-transform-sql/pom.xml
rename to seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml
index 6662d8b..3b9bcb2 100644
--- a/seatunnel-transforms/plugin-spark-transform-sql/pom.xml
+++ b/seatunnel-transforms/seatunnel-transform-spark-sql/pom.xml
@@ -27,7 +27,7 @@
</parent>
<modelVersion>4.0.0</modelVersion>
- <artifactId>plugin-spark-transform-sql</artifactId>
+ <artifactId>seatunnel-transform-spark-sql</artifactId>
<dependencies>
<dependency>
diff --git a/seatunnel-transforms/plugin-spark-transform-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform b/seatunnel-transforms/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
rename to seatunnel-transforms/seatunnel-transform-spark-sql/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkTransform
diff --git a/seatunnel-transforms/plugin-spark-transform-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala b/seatunnel-transforms/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala
similarity index 100%
rename from seatunnel-transforms/plugin-spark-transform-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala
rename to seatunnel-transforms/seatunnel-transform-spark-sql/src/main/scala/org/apache/seatunnel/spark/transform/Sql.scala