Skip to content

Commit 5063d24

Browse files
committed
[feat] add dirty manager
1 parent ea79c40 commit 5063d24

7 files changed

Lines changed: 3 additions & 0 deletions

File tree

dirtyDataManager/console/src/main/java/com/dtstack/flink/sql/dirty/print/ConsoleDirtyDataConsumer.java renamed to dirtyData/console/src/main/java/com/dtstack/flink/sql/dirty/print/ConsoleDirtyDataConsumer.java

File renamed without changes.

dirtyDataManager/console/src/test/java/com/dtstack/flink/sql/dirty/print/TestPrintDirtyDataConsumer.java renamed to dirtyData/console/src/test/java/com/dtstack/flink/sql/dirty/print/TestPrintDirtyDataConsumer.java

File renamed without changes.

dirtyDataManager/mysql/src/main/java/com/dtstack/flink/sql/dirty/mysql/MysqlDirtyDataConsumer.java renamed to dirtyData/mysql/src/main/java/com/dtstack/flink/sql/dirty/mysql/MysqlDirtyDataConsumer.java

File renamed without changes.

pom.xml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,9 @@
3838
<module>tidb</module>
3939
<module>kingbase</module>
4040
<module>aws</module>
41+
42+
<!-- 脏数据插件 -->
43+
<module>dirtyData</module>
4144
<!-- <module>localTest</module>-->
4245

4346
</modules>

0 commit comments

Comments
 (0)