This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 3f054d1df67 Move package of (#32554)
3f054d1df67 is described below
commit 3f054d1df676cb83bdcf2e495349fa6c41032a84
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Aug 16 13:48:07 2024 +0800
Move package of (#32554)
---
.../{dumper/type => binlog/data}/MySQLBinlogDataHandler.java | 6 +++---
.../data}/binary/MySQLBinlogBinaryStringHandler.java | 2 +-
.../data}/unsigned/MySQLBinlogUnsignedNumberHandler.java | 2 +-
.../unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java | 12 ++++++------
.../unsigned/impl/MySQLBinlogUnsignedBigintHandler.java | 4 ++--
.../data}/unsigned/impl/MySQLBinlogUnsignedIntHandler.java | 4 ++--
.../unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java | 4 ++--
.../unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java | 4 ++--
.../unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java | 4 ++--
.../pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java | 2 +-
.../data}/unsigned/impl/MySQLUnsignedBigintHandlerTest.java | 2 +-
.../data}/unsigned/impl/MySQLUnsignedIntHandlerTest.java | 2 +-
.../unsigned/impl/MySQLUnsignedMediumintHandlerTest.java | 2 +-
.../unsigned/impl/MySQLUnsignedSmallintHandlerTest.java | 2 +-
.../data}/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java | 2 +-
15 files changed, 27 insertions(+), 27 deletions(-)
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/MySQLBinlogDataHandler.java
similarity index 86%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/MySQLBinlogDataHandler.java
index d88384d4e25..c95c147f8b1 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/MySQLBinlogDataHandler.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type;
+package org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.binary.MySQLBinlogBinaryStringHandler;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandlerEngine;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.binary.MySQLBinlogBinaryStringHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandlerEngine;
import
org.apache.shardingsphere.db.protocol.mysql.packet.binlog.row.column.value.string.MySQLBinaryString;
import java.io.Serializable;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/binary/MySQLBinlogBinaryStringHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/binary/MySQLBinlogBinaryStringHandler.java
similarity index 95%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/binary/MySQLBinlogBinaryStringHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/binary/MySQLBinlogBinaryStringHandler.java
index d06f5b3e439..1f77e1acbb8 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/binary/MySQLBinlogBinaryStringHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/binary/MySQLBinlogBinaryStringHandler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.binary;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.binary;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandler.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandler.java
index 4c9590f4f72..e9352e4eb1c 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandler.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned;
import java.io.Serializable;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
similarity index 77%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
index 62628a6e3ad..881c8d9e9f7 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/MySQLBinlogUnsignedNumberHandlerEngine.java
@@ -15,15 +15,15 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl.MySQLBinlogUnsignedBigintHandler;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl.MySQLBinlogUnsignedIntHandler;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl.MySQLBinlogUnsignedMediumintHandler;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl.MySQLBinlogUnsignedSmallintHandler;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl.MySQLBinlogUnsignedTinyintHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl.MySQLBinlogUnsignedBigintHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl.MySQLBinlogUnsignedIntHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl.MySQLBinlogUnsignedSmallintHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl.MySQLBinlogUnsignedTinyintHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl.MySQLBinlogUnsignedMediumintHandler;
import java.io.Serializable;
import java.util.HashMap;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
similarity index 85%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
index 0c39bef3070..83c6cdcb51d 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedBigintHandler.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandler;
import java.math.BigInteger;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
similarity index 84%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
index 8f810fac443..1319dc5214a 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedIntHandler.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandler;
/**
* MySQL binlog unsigned int handler.
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
similarity index 85%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
index bdf8eaabbe7..7d9499e1107 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedMediumintHandler.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandler;
/**
* MySQL binlog unsigned mediumint handler.
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
similarity index 85%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
index ba9aa715cb7..081880fac20 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedSmallintHandler.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandler;
/**
* MySQL binlog unsigned smallint handler.
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
similarity index 84%
rename from
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
rename to
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
index de3bb28e088..7492a250776 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLBinlogUnsignedTinyintHandler.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.MySQLBinlogUnsignedNumberHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.MySQLBinlogUnsignedNumberHandler;
/**
* MySQL binlog unsigned tinyint handler.
diff --git
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
index 0487b674c8d..f021bd6abec 100644
---
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
+++
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
@@ -40,7 +40,7 @@ import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.UpdateR
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.WriteRowsEvent;
import org.apache.shardingsphere.data.pipeline.mysql.ingest.client.ConnectInfo;
import
org.apache.shardingsphere.data.pipeline.mysql.ingest.client.MySQLBinlogClient;
-import
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataHandler;
+import
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.MySQLBinlogDataHandler;
import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
import
org.apache.shardingsphere.infra.database.core.connector.ConnectionProperties;
import
org.apache.shardingsphere.infra.database.core.connector.ConnectionPropertiesParser;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
similarity index 94%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
index 6dbf70f2b08..27c9d64ab3b 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedBigintHandlerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
import org.junit.jupiter.api.Test;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedIntHandlerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedIntHandlerTest.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedIntHandlerTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedIntHandlerTest.java
index 7676a54bcf6..3a5de9af856 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedIntHandlerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedIntHandlerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
import org.junit.jupiter.api.Test;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
index 7ce0f6dfc88..897467b9ebe 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedMediumintHandlerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
import org.junit.jupiter.api.Test;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
index c25f4b68f52..130800c0262 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedSmallintHandlerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
import org.junit.jupiter.api.Test;
diff --git
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
similarity index 93%
rename from
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
rename to
kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
index 5e25ceed761..252884c564c 100644
---
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
+++
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/binlog/data/unsigned/impl/MySQLUnsignedTinyintHandlerTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.unsigned.impl;
+package
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.data.unsigned.impl;
import org.junit.jupiter.api.Test;
