This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 5a97f07 Fix: Duplicate data appears when querying
information_schemata (#13904)
add 1f04217 Separate cdc basic classes from scaling-core module and move
to cdc-core module (#13928)
No new revisions were added by this update.
Summary of changes:
.../shardingsphere-cdc-core/pom.xml | 5 +++
.../shardingsphere/cdc/core/CDCDataChangeType.java | 11 ++----
.../cdc/core}/channel/AckCallback.java | 4 +--
.../shardingsphere/cdc/core}/channel/Channel.java | 4 +--
.../cdc/core}/channel/MemoryChannel.java | 10 +++---
.../distribution/AbstractBitSetChannel.java | 4 +--
.../distribution/AutoAcknowledgeChannel.java | 4 +--
.../core}/channel/distribution/BitSetChannel.java | 4 +--
.../channel/distribution/BlockingQueueChannel.java | 10 +++---
.../channel/distribution/DistributionChannel.java | 14 ++++----
.../core}/channel/distribution/ManualBitSet.java | 2 +-
.../cdc}/core/config/DumperConfiguration.java | 6 ++--
.../core/config/InventoryDumperConfiguration.java | 2 +-
.../cdc/core}/datasource/DataSourceFactory.java | 2 +-
.../cdc/core}/datasource/DataSourceManager.java | 36 +++++++++-----------
.../cdc/core}/datasource/DataSourceWrapper.java | 2 +-
.../cdc/core}/datasource/MetaDataManager.java | 4 +--
.../cdc/core}/dumper/AbstractInventoryDumper.java | 39 +++++++++++-----------
.../shardingsphere/cdc/core}/dumper/Dumper.java | 4 +--
.../cdc/core}/dumper/IncrementalDumper.java | 2 +-
.../cdc/core}/dumper/InventoryDumper.java | 2 +-
.../cdc/core/position/CDCPosition.java | 6 ++--
.../cdc/core}/position/FinishedPosition.java | 4 +--
.../cdc/core}/position/PlaceholderPosition.java | 4 +--
.../cdc/core}/position/PositionInitializer.java | 6 ++--
.../cdc/core}/position/PrimaryKeyPosition.java | 4 +--
.../shardingsphere/cdc/core}/record/Column.java | 2 +-
.../cdc/core}/record/DataRecord.java | 6 ++--
.../cdc/core}/record/FinishedRecord.java | 6 ++--
.../cdc/core}/record/GroupedDataRecord.java | 2 +-
.../cdc/core}/record/PlaceholderRecord.java | 6 ++--
.../shardingsphere/cdc/core}/record/Record.java | 6 ++--
.../cdc}/core/util/ReflectionUtil.java | 2 +-
.../shardingsphere/cdc}/core/util/ThreadUtil.java | 2 +-
.../cdc/core}/channel/MemoryChannelTest.java | 16 +++------
.../distribution/AutoAcknowledgeChannelTest.java | 6 ++--
.../distribution/DistributionChannelTest.java | 26 +++++----------
.../channel/distribution/ManualBitSetTest.java | 4 +--
.../core}/datasource/DataSourceWrapperTest.java | 13 ++++----
.../cdc/core}/datasource/MetaDataManagerTest.java | 2 +-
.../core}/position/PlaceholderPositionTest.java | 2 +-
.../cdc/core}/position/PrimaryKeyPositionTest.java | 2 +-
.../cdc/core}/record/DataRecordTest.java | 4 +--
.../common/constant/MigrationConstant.java | 18 ++++------
.../job/preparer/AbstractDataSourcePreparer.java | 4 +--
.../scaling/core/api/ScalingAPIFactory.java | 6 ++--
.../impl/AbstractSingleTableDataCalculator.java | 4 +--
.../core/api/impl/GovernanceRepositoryAPIImpl.java | 10 +++---
.../scaling/core/api/impl/ScalingAPIImpl.java | 6 ++--
.../UnexpectedDataRecordOrderException.java | 2 +-
.../scaling/core/common/record/RecordUtil.java | 2 ++
.../sqlbuilder/AbstractScalingSQLBuilder.java | 4 +--
.../core/common/sqlbuilder/ScalingSQLBuilder.java | 4 +--
.../scaling/core/config/TaskConfiguration.java | 1 +
.../core/executor/dumper/DumperFactory.java | 16 +++++----
.../core/executor/importer/AbstractImporter.java | 24 ++++++-------
.../core/executor/importer/DataRecordMerger.java | 38 ++++++++++-----------
.../scaling/core/executor/importer/Importer.java | 2 +-
.../core/executor/importer/ImporterFactory.java | 2 +-
.../core/executor/importer/ImporterListener.java | 2 +-
.../core/executor/job/ScalingJobExecutor.java | 6 ++--
.../consistency/DataConsistencyCheckerImpl.java | 4 +--
.../job/environment/ScalingEnvironmentManager.java | 4 +--
.../job/position/PositionInitializerFactory.java | 1 +
.../core/job/preparer/ScalingJobPreparer.java | 25 ++++++++++----
.../preparer/splitter/InventoryTaskSplitter.java | 26 +++++++--------
.../scaling/core/job/progress/JobProgress.java | 8 ++---
.../job/progress/yaml/JobProgressYamlSwapper.java | 6 ++--
.../scaling/core/job/task/ScalingTaskFactory.java | 4 +--
.../core/job/task/incremental/IncrementalTask.java | 12 +++----
.../task/incremental/IncrementalTaskProgress.java | 6 ++--
.../core/job/task/inventory/InventoryTask.java | 16 ++++-----
.../job/task/inventory/InventoryTaskProgress.java | 4 +--
.../scaling/core/spi/ScalingEntry.java | 6 ++--
.../scaling/core/util/ScalingTaskUtil.java | 2 +-
.../ShardingRuleJobConfigurationPreparer.java | 2 +-
.../api/impl/GovernanceRepositoryAPIImplTest.java | 20 +++++------
.../scaling/core/api/impl/ScalingAPIImplTest.java | 2 +-
.../common/datasource/DataSourceManagerTest.java | 29 ++++++++--------
.../core/executor/engine/ExecuteEngineTest.java | 2 +-
.../executor/importer/AbstractImporterTest.java | 14 ++++----
.../executor/importer/AbstractSqlBuilderTest.java | 6 ++--
.../executor/importer/DataRecordMergerTest.java | 30 ++++++++---------
.../scaling/core/fixture/FixtureImporter.java | 4 +--
.../core/fixture/FixtureIncrementalDumper.java | 10 +++---
.../core/fixture/FixtureInventoryDumper.java | 6 ++--
.../core/fixture/FixturePositionInitializer.java | 4 +--
.../scaling/core/fixture/FixtureScalingEntry.java | 6 ++--
.../scaling/core/job/FinishedCheckJobTest.java | 2 +-
.../scaling/core/job/ScalingJobTest.java | 2 +-
.../job/check/DataConsistencyCheckerImplTest.java | 2 +-
.../splitter/InventoryTaskSplitterTest.java | 6 ++--
.../scaling/core/job/progress/JobProgressTest.java | 10 +++---
.../job/task/incremental/IncrementalTaskTest.java | 2 +-
.../core/job/task/inventory/InventoryTaskTest.java | 11 +++---
.../scaling/mysql/binlog/BinlogPosition.java | 4 +--
.../scaling/mysql/component/MySQLImporter.java | 2 +-
.../mysql/component/MySQLIncrementalDumper.java | 32 +++++++++---------
.../mysql/component/MySQLInventoryDumper.java | 6 ++--
.../mysql/component/MySQLPositionInitializer.java | 2 +-
.../mysql/component/MySQLScalingSQLBuilder.java | 4 +--
.../DefaultMySQLSingleTableDataCalculator.java | 2 +-
.../component/checker/MySQLDataSourcePreparer.java | 2 +-
.../scaling/mysql/client/MySQLClientTest.java | 2 +-
.../netty/MySQLBinlogEventPacketDecoderTest.java | 2 +-
.../client/netty/MySQLNegotiateHandlerTest.java | 2 +-
.../netty/MySQLNegotiatePackageDecoderTest.java | 2 +-
.../scaling/mysql/component/MySQLImporterTest.java | 6 ++--
.../component/MySQLIncrementalDumperTest.java | 22 ++++++------
.../mysql/component/MySQLJdbcDumperTest.java | 6 ++--
.../component/MySQLScalingSQLBuilderTest.java | 6 ++--
.../opengauss/component/OpenGaussImporter.java | 2 +-
.../component/OpenGaussPositionInitializer.java | 2 +-
.../component/OpenGaussScalingSQLBuilder.java | 4 +--
.../opengauss/component/OpenGaussWalDumper.java | 22 ++++++------
.../checker/OpenGaussDataSourcePreparer.java | 2 +-
.../opengauss/wal/decode/MppdbDecodingPlugin.java | 8 ++---
.../postgresql/component/PostgreSQLImporter.java | 2 +-
.../component/PostgreSQLInventoryDumper.java | 6 ++--
.../component/PostgreSQLPositionInitializer.java | 2 +-
.../component/PostgreSQLScalingSQLBuilder.java | 4 +--
.../postgresql/component/PostgreSQLWalDumper.java | 14 ++++----
.../scaling/postgresql/wal/WalEventConverter.java | 22 ++++++------
.../scaling/postgresql/wal/WalPosition.java | 4 +--
.../postgresql/wal/decode/TestDecodingPlugin.java | 8 ++---
.../component/PostgreSQLImporterTest.java | 6 ++--
.../component/PostgreSQLJdbcDumperTest.java | 6 ++--
.../component/PostgreSQLScalingSQLBuilderTest.java | 4 +--
.../component/PostgreSQLWalDumperTest.java | 6 ++--
.../postgresql/wal/WalEventConverterTest.java | 18 +++++-----
130 files changed, 492 insertions(+), 499 deletions(-)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/constant/ScalingConstant.java
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core/CDCDataChangeType.java
(84%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/AckCallback.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/Channel.java
(91%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/MemoryChannel.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/AbstractBitSetChannel.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/AutoAcknowledgeChannel.java
(91%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/BitSetChannel.java
(93%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/BlockingQueueChannel.java
(85%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/DistributionChannel.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/channel/distribution/ManualBitSet.java
(98%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc}/core/config/DumperConfiguration.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc}/core/config/InventoryDumperConfiguration.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/datasource/DataSourceFactory.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/datasource/DataSourceManager.java
(73%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/datasource/DataSourceWrapper.java
(98%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/datasource/MetaDataManager.java
(97%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/dumper/AbstractInventoryDumper.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/dumper/Dumper.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/dumper/IncrementalDumper.java
(93%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/dumper/InventoryDumper.java
(93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/ScalingPosition.java
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core/position/CDCPosition.java
(85%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/position/FinishedPosition.java
(86%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/position/PlaceholderPosition.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/position/PositionInitializer.java
(89%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/position/PrimaryKeyPosition.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/Column.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/DataRecord.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/FinishedRecord.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/GroupedDataRecord.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/PlaceholderRecord.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc/core}/record/Record.java
(85%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc}/core/util/ReflectionUtil.java
(98%)
copy
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/main/java/org/apache/shardingsphere/cdc}/core/util/ThreadUtil.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/channel/MemoryChannelTest.java
(74%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/channel/distribution/AutoAcknowledgeChannelTest.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/channel/distribution/DistributionChannelTest.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/channel/distribution/ManualBitSetTest.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/datasource/DataSourceWrapperTest.java
(98%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/datasource/MetaDataManagerTest.java
(98%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/position/PlaceholderPositionTest.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/position/PrimaryKeyPositionTest.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/src/test/java/org/apache/shardingsphere/cdc/core}/record/DataRecordTest.java
(94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/util/ThreadUtil.java
=>
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-migration-common/src/main/java/org/apache/shardingsphere/migration/common/constant/MigrationConstant.java
(72%)
