[Improve][Translation][Flink] Optimize code structure & remove redund…

…ant code (apache#4527)
ic4y · Apr 13, 2023 · 3d02e1d · 3d02e1d
1 parent 673afa4
commit 3d02e1d
Show file tree

Hide file tree

Showing 38 changed files with 82 additions and 1,403 deletions.
diff --git a/seatunnel-translation/seatunnel-translation-flink/pom.xml b/seatunnel-translation/seatunnel-translation-flink/pom.xml
@@ -29,6 +29,7 @@
     <modules>
         <module>seatunnel-translation-flink-13</module>
         <module>seatunnel-translation-flink-15</module>
+        <module>seatunnel-translation-flink-common</module>
     </modules>
 
     <dependencies>

diff --git a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/pom.xml b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/pom.xml
@@ -23,10 +23,22 @@
     </parent>
 
     <artifactId>seatunnel-translation-flink-13</artifactId>
-    <name>SeaTunnel : Translation : Flink : 1.3</name>
+    <name>SeaTunnel : Translation : Flink : 1.13</name>
 
     <dependencies>
 
+        <dependency>
+            <groupId>org.apache.seatunnel</groupId>
+            <artifactId>seatunnel-translation-flink-common</artifactId>
+            <version>${project.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>*</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-table-planner_${scala.binary.version}</artifactId>

diff --git a/...slation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSink.java b/...slation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSink.java
diff --git a/...n-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSinkWriter.java b/...n-flink-13/src/main/java/org/apache/seatunnel/translation/flink/sink/FlinkSinkWriter.java