This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from b04b7ac Avoid blocked in SQLStatementParserEngineFactory (#14131)
add 9969479 Refactor scaling-core into pipeline-core and sharding-core,
prepare for refactoring of pipeline-spi (#14135)
No new revisions were added by this update.
Summary of changes:
.../shardingsphere-sharding-core/pom.xml | 5 +
.../schedule/JobShardingRuleAlteredDetector.java | 2 +-
...hardingRuleAlteredJobConfigurationPreparer.java | 20 ++--
...pipeline.spi.rulealtered.JobRuleAlteredDetector | 0
...rulealtered.RuleAlteredJobConfigurationPreparer | 2 +-
.../shardingsphere-data-pipeline-core/pom.xml | 10 +-
.../data/pipeline/api/PipelineJobAPI.java | 15 +--
.../data/pipeline/api/PipelineJobAPIFactory.java | 28 ++++--
.../check/consistency}/DataCalculateParameter.java | 2 +-
.../consistency/DataConsistencyCheckResult.java | 2 +-
.../config/ingest}/DumperConfiguration.java | 4 +-
.../ingest}/InventoryDumperConfiguration.java | 2 +-
.../config/rulealtered}/HandleConfiguration.java | 5 +-
.../config/rulealtered}/ImporterConfiguration.java | 2 +-
.../api/config/rulealtered}/JobConfiguration.java | 11 ++-
.../api/config/rulealtered}/RuleConfiguration.java | 2 +-
.../api/config/rulealtered}/TaskConfiguration.java | 4 +-
.../config/rulealtered}/WorkflowConfiguration.java | 2 +-
.../api/config/server}/ServerConfiguration.java | 2 +-
.../pipeline/api/datanode}/JobDataNodeEntry.java | 2 +-
.../pipeline/api/datanode}/JobDataNodeLine.java | 2 +-
.../api}/executor/AbstractLifecycleExecutor.java | 2 +-
.../pipeline/api}/executor/LifecycleExecutor.java | 3 +-
.../{core => api}/ingest/channel/Channel.java | 4 +-
.../ingest/position/FinishedPosition.java | 2 +-
.../ingest/position/IngestPosition.java | 2 +-
.../ingest/position/PlaceholderPosition.java | 2 +-
.../ingest/position/PrimaryKeyPosition.java | 2 +-
.../{core => api}/ingest/record/Column.java | 2 +-
.../{core => api}/ingest/record/DataRecord.java | 4 +-
.../ingest/record/FinishedRecord.java | 4 +-
.../ingest/record/GroupedDataRecord.java | 2 +-
.../ingest/record/PlaceholderRecord.java | 4 +-
.../{core => api}/ingest/record/Record.java | 4 +-
.../data/pipeline/api}/job/JobStatus.java | 2 +-
.../pipeline/api}/job/progress/JobProgress.java | 32 ++-----
.../pojo}/DataConsistencyCheckAlgorithmInfo.java | 2 +-
.../data/pipeline/api/pojo}/JobInfo.java | 2 +-
.../prepare/datasource}/ActualTableDefinition.java | 2 +-
.../datasource}/PrepareTargetTablesParameter.java | 6 +-
.../datasource}/TableDefinitionSQLType.java | 2 +-
.../api/task/progress}/IncrementalTaskDelay.java | 2 +-
.../task/progress}/IncrementalTaskProgress.java | 7 +-
.../api/task/progress}/InventoryTaskProgress.java | 7 +-
.../pipeline/api/task/progress/TaskProgress.java | 6 +-
.../core/api/GovernanceRepositoryAPI.java | 8 +-
.../data/pipeline/core/api/PipelineAPIFactory.java | 54 +++--------
.../core/api/impl/GovernanceRepositoryAPIImpl.java | 35 ++++---
.../pipeline/core/api/impl/PipelineJobAPIImpl.java | 98 +++++++++++---------
.../AbstractSingleTableDataCalculator.java | 4 +-
.../check/consistency/DataConsistencyChecker.java | 7 +-
.../consistency/DataConsistencyCheckerImpl.java | 19 ++--
.../DefaultDataConsistencyCheckAlgorithm.java | 8 +-
.../SingleTableDataCalculatorRegistry.java | 4 +-
.../datasource}/AbstractDataSourceChecker.java | 15 +--
.../yaml/ServerConfigurationYamlSwapper.java | 4 +-
.../server}/yaml/YamlServerConfiguration.java | 2 +-
.../core}/exception/DataCheckFailException.java | 2 +-
.../exception/PipelineJobCreationException.java | 16 ++--
.../exception/PipelineJobExecutionException.java | 12 +--
.../exception/PipelineJobNotFoundException.java | 8 +-
.../PipelineJobPrepareFailedException.java | 10 +-
.../UnexpectedDataRecordOrderException.java | 4 +-
.../pipeline/core/execute}/ExecuteCallback.java | 2 +-
.../data/pipeline/core/execute}/ExecuteEngine.java | 4 +-
.../core/execute}/FinishedCheckJobExecutor.java | 16 ++--
.../pipeline/core/execute/PipelineJobExecutor.java | 20 ++--
.../pipeline/core}/importer/AbstractImporter.java | 42 +++++----
.../pipeline/core}/importer/DataRecordMerger.java | 12 +--
.../pipeline/core/ingest/channel/AckCallback.java | 2 +-
.../core/ingest/channel/MemoryChannel.java | 3 +-
.../distribution/AbstractBitSetChannel.java | 2 +-
.../distribution/AutoAcknowledgeChannel.java | 2 +-
.../ingest/channel/distribution/BitSetChannel.java | 2 +-
.../channel/distribution/BlockingQueueChannel.java | 2 +-
.../channel/distribution/DistributionChannel.java | 10 +-
.../ingest/dumper/AbstractInventoryDumper.java | 25 ++---
.../data/pipeline}/core/job/FinishedCheckJob.java | 31 ++++---
.../job/progress/yaml/JobProgressYamlSwapper.java | 16 ++--
.../core/job/progress/yaml/YamlJobProgress.java | 4 +-
.../core/prepare}/InventoryTaskSplitter.java | 43 ++++-----
.../datasource}/AbstractDataSourcePreparer.java | 10 +-
.../data/pipeline/core}/record/RecordUtil.java | 6 +-
.../sqlbuilder/AbstractPipelineSQLBuilder.java | 11 ++-
.../data/pipeline/core/task}/IncrementalTask.java | 36 +++----
.../data/pipeline/core/task}/InventoryTask.java | 36 +++----
.../data/pipeline/core/task/PipelineTask.java | 12 +--
.../pipeline/core/task/PipelineTaskFactory.java | 15 ++-
...dleRuleAlteredJobCompletionDetectAlgorithm.java | 10 +-
.../scenario/rulealtered/RuleAlteredContext.java | 36 +++----
.../scenario/rulealtered/RuleAlteredJob.java | 25 +++--
.../rulealtered/RuleAlteredJobContext.java | 23 ++---
.../rulealtered/RuleAlteredJobPreparer.java | 53 +++++------
.../RuleAlteredJobProgressDetector.java | 19 ++--
.../rulealtered/RuleAlteredJobScheduler.java | 43 ++++-----
.../rulealtered/RuleAlteredJobSchedulerCenter.java | 38 ++++----
.../scenario/rulealtered/RuleAlteredJobWorker.java | 26 +++---
.../consistency/DataConsistencyCheckAlgorithm.java | 6 +-
.../consistency}/SingleTableDataCalculator.java | 5 +-
.../spi/check/datasource}/DataSourceChecker.java | 3 +-
.../data/pipeline/spi}/importer/Importer.java | 6 +-
.../pipeline/spi}/importer/ImporterListener.java | 4 +-
.../{core => spi}/ingest/dumper/Dumper.java | 6 +-
.../ingest/dumper/IncrementalDumper.java | 2 +-
.../ingest/dumper/InventoryDumper.java | 2 +-
.../ingest/position/PositionInitializer.java | 4 +-
.../spi/rulealtered}/DataSourcePreparer.java | 4 +-
.../spi/rulealtered}/JobRuleAlteredDetector.java | 2 +-
.../RuleAlteredJobCompletionDetectAlgorithm.java | 8 +-
.../RuleAlteredJobConfigurationPreparer.java | 13 +--
.../spi/sqlbuilder/PipelineSQLBuilder.java | 12 +--
.../scaling/core/job/check/EnvironmentChecker.java | 5 +-
.../core/job/check/EnvironmentCheckerFactory.java | 12 +--
.../scaling/core/job}/dumper/DumperFactory.java | 12 +--
.../job/environment/ScalingEnvironmentManager.java | 7 +-
.../core/job}/importer/ImporterFactory.java | 5 +-
.../job/position/PositionInitializerFactory.java | 2 +-
.../job}/sqlbuilder/ScalingSQLBuilderFactory.java | 5 +-
.../scaling/core/spi/ScalingEntry.java | 13 +--
.../scaling/core/spi/ScalingEntryLoader.java | 0
...shardingsphere.data.pipeline.api.PipelineJobAPI | 2 +-
...check.consistency.DataConsistencyCheckAlgorithm | 2 +-
...altered.RuleAlteredJobCompletionDetectAlgorithm | 2 +-
.../mysql/ingest/MySQLIncrementalDumper.java | 22 ++---
.../mysql/ingest/MySQLInventoryDumper.java | 2 +-
.../mysql/ingest/MySQLPositionInitializer.java | 2 +-
.../mysql/ingest/binlog/BinlogPosition.java | 2 +-
.../mysql/ingest/MySQLIncrementalDumperTest.java | 8 +-
.../pipeline/mysql/ingest/MySQLJdbcDumperTest.java | 4 +-
.../ingest/OpenGaussPositionInitializer.java | 2 +-
.../opengauss/ingest/OpenGaussWalDumper.java | 16 ++--
.../ingest/PostgreSQLInventoryDumper.java | 2 +-
.../ingest/PostgreSQLPositionInitializer.java | 2 +-
.../postgresql/ingest/PostgreSQLWalDumper.java | 12 +--
.../postgresql/ingest/wal/WalEventConverter.java | 10 +-
.../postgresql/ingest/wal/WalPosition.java | 2 +-
.../ingest/PostgreSQLJdbcDumperTest.java | 4 +-
.../postgresql/ingest/PostgreSQLWalDumperTest.java | 2 +-
.../ingest/wal/WalEventConverterTest.java | 8 +-
.../shardingsphere-data-pipeline-spi/pom.xml | 12 +++
.../proxy/backend/context/ProxyContext.java | 4 +-
.../distsql/DistSQLBackendHandlerFactoryTest.java | 6 +-
.../shardingsphere-proxy-bootstrap/pom.xml | 5 +
.../proxy/initializer/BootstrapInitializer.java | 12 +--
.../frontend/mysql/err/MySQLErrPacketFactory.java | 6 +-
shardingsphere-scaling/pom.xml | 1 -
.../shardingsphere-scaling-core/pom.xml | 103 ---------------------
.../scaling/core/job/progress/JobProgressTest.java | 89 ------------------
...g.core.api.ScalingDataConsistencyCheckAlgorithm | 18 ----
...here.scaling.core.api.SingleTableDataCalculator | 18 ----
.../shardingsphere-scaling-mysql/pom.xml | 2 +-
.../scaling/mysql/MySQLScalingEntry.java | 6 +-
.../scaling/mysql/component/MySQLImporter.java | 10 +-
...QLBuilder.java => MySQLPipelineSQLBuilder.java} | 12 +--
.../DefaultMySQLSingleTableDataCalculator.java | 14 +--
.../component/checker/MySQLDataSourceChecker.java | 18 ++--
.../component/checker/MySQLDataSourcePreparer.java | 18 ++--
.../component/checker/MySQLEnvironmentChecker.java | 2 +-
...pi.check.consistency.SingleTableDataCalculator} | 0
.../component/MySQLDataSourceCheckerTest.java | 10 +-
.../component/MySQLDataSourcePreparerTest.java | 12 +--
.../scaling/mysql/component/MySQLImporterTest.java | 6 +-
...rTest.java => MySQLPipelineSQLBuilderTest.java} | 10 +-
.../scaling/opengauss/OpenGaussScalingEntry.java | 6 +-
.../opengauss/component/OpenGaussImporter.java | 10 +-
...ilder.java => OpenGaussPipelineSQLBuilder.java} | 12 +--
.../checker/OpenGaussDataSourcePreparer.java | 20 ++--
.../shardingsphere-scaling-postgresql/pom.xml | 2 +-
.../scaling/postgresql/PostgreSQLScalingEntry.java | 6 +-
.../postgresql/component/PostgreSQLImporter.java | 10 +-
...lder.java => PostgreSQLPipelineSQLBuilder.java} | 14 +--
...DefaultPostgreSQLSingleTableDataCalculator.java | 8 +-
.../checker/PostgreSQLDataSourceChecker.java | 16 ++--
.../checker/PostgreSQLEnvironmentChecker.java | 2 +-
...pi.check.consistency.SingleTableDataCalculator} | 0
.../component/PostgreSQLDataSourceCheckerTest.java | 6 +-
.../component/PostgreSQLImporterTest.java | 6 +-
....java => PostgreSQLPipelineSQLBuilderTest.java} | 8 +-
.../shardingsphere-scaling-distsql-handler/pom.xml | 2 +-
.../handler/CheckScalingQueryResultSet.java | 8 +-
.../distsql/handler/CheckoutScalingUpdater.java | 4 +-
.../distsql/handler/DropScalingUpdater.java | 4 +-
.../distsql/handler/ResetScalingUpdater.java | 6 +-
.../ShowScalingCheckAlgorithmsQueryResultSet.java | 4 +-
.../ShowScalingJobStatusQueryResultSet.java | 4 +-
.../handler/ShowScalingListQueryResultSet.java | 4 +-
.../distsql/handler/StartScalingUpdater.java | 4 +-
.../handler/StopScalingSourceWritingUpdater.java | 4 +-
.../distsql/handler/StopScalingUpdater.java | 4 +-
...owScalingCheckAlgorithmsQueryResultSetTest.java | 10 +-
.../parser/core/ScalingSQLStatementVisitor.java | 2 +-
shardingsphere-test/pom.xml | 1 +
.../pom.xml | 7 +-
.../test/mysql/env/ITEnvironmentContext.java | 4 +-
.../shardingsphere-pipeline-test}/pom.xml | 29 +++---
.../yaml/ServerConfigurationYamlSwapperTest.java | 6 +-
.../api/datanode}/JobDataNodeEntryTest.java | 2 +-
.../api/datanode}/JobDataNodeLineTest.java | 2 +-
.../api/impl/GovernanceRepositoryAPIImplTest.java | 54 ++++++-----
.../pipeline/api/impl/PipelineJobAPIImplTest.java | 97 +++++++++----------
.../DataConsistencyCheckerImplTest.java | 18 ++--
...ngDefaultDataConsistencyCheckAlgorithmTest.java | 8 +-
.../SingleTableDataCalculatorRegistryTest.java | 7 +-
.../datasource}/AbstractDataSourceCheckerTest.java | 11 +--
.../core}/datasource/DataSourceManagerTest.java | 8 +-
.../core/datasource/DataSourceWrapperTest.java | 0
.../core/datasource/MetaDataManagerTest.java | 0
.../pipeline/core/execute}/ExecuteEngineTest.java | 4 +-
.../pipeline}/core/fixture/EmbedTestingServer.java | 2 +-
.../FixtureDataConsistencyCheckAlgorithm.java | 9 +-
.../core/fixture/FixtureDataSourceChecker.java | 4 +-
.../core/fixture/FixtureDataSourcePreparer.java | 6 +-
.../core/fixture/FixtureEnvironmentChecker.java | 6 +-
.../FixtureH2SingleTableDataCalculator.java | 8 +-
.../pipeline}/core/fixture/FixtureImporter.java | 8 +-
.../core/fixture/FixtureIncrementalDumper.java | 10 +-
.../core/fixture/FixtureInventoryDumper.java | 4 +-
.../core/fixture/FixturePipelineSQLBuilder.java | 8 +-
.../core/fixture/FixturePositionInitializer.java | 6 +-
...ureRuleAlteredJobCompletionDetectAlgorithm.java | 6 +-
.../core/fixture/FixtureScalingEntry.java | 16 ++--
.../core}/importer/AbstractImporterTest.java | 38 ++++----
.../core}/importer/DataRecordMergerTest.java | 12 +--
.../core/ingest/channel/MemoryChannelTest.java | 6 +-
.../distribution/AutoAcknowledgeChannelTest.java | 4 +-
.../distribution/DistributionChannelTest.java | 12 +--
.../channel/distribution/ManualBitSetTest.java | 0
.../ingest/position/PlaceholderPositionTest.java | 1 +
.../ingest/position/PrimaryKeyPositionTest.java | 1 +
.../core/ingest/record/DataRecordTest.java | 4 +-
.../pipeline}/core/job/FinishedCheckJobTest.java | 28 +++---
.../core/job/progress/JobProgressTest.java | 71 ++++++++++++++
.../core/prepare}/InventoryTaskSplitterTest.java | 18 ++--
.../AbstractDataSourcePreparerTest.java | 6 +-
.../pipeline/core/task}/IncrementalTaskTest.java | 21 ++---
.../pipeline/core/task}/InventoryTaskTest.java | 22 ++---
.../data/pipeline}/core/util/ResourceUtil.java | 8 +-
...uleAlteredJobCompletionDetectAlgorithmTest.java | 44 ++++-----
.../scenario/rulealtered/RuleAlteredJobTest.java | 25 +++--
.../data/pipeline}/spi/ScalingEntryLoaderTest.java | 6 +-
.../spi/sqlbuilder/PipelineSQLBuilderTest.java | 27 +++---
...check.consistency.DataConsistencyCheckAlgorithm | 2 +-
...spi.check.consistency.SingleTableDataCalculator | 2 +-
...altered.RuleAlteredJobCompletionDetectAlgorithm | 2 +-
...he.shardingsphere.scaling.core.spi.ScalingEntry | 2 +-
.../config_sharding_sphere_jdbc_source.yaml | 0
.../config_sharding_sphere_jdbc_target.yaml | 0
.../resources/config_standard_jdbc_target.yaml | 0
.../src/test/resources/governance-repository.yaml | 0
.../src/test/resources/job-progress.yaml | 0
.../src/test/resources/logback-test.xml | 4 +-
251 files changed, 1303 insertions(+), 1416 deletions(-)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core}/src/main/java/org/apache/shardingsphere/sharding/schedule/JobShardingRuleAlteredDetector.java
(96%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/sharding/schedule/ShardingJobConfigurationPreparer.java
=>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/schedule/ShardingRuleAlteredJobConfigurationPreparer.java
(94%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JobRuleAlteredDetector
=>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.JobRuleAlteredDetector
(100%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.ScalingClusterAutoSwitchAlgorithm
=>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.RuleAlteredJobConfigurationPreparer
(89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/ScalingAPI.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobAPI.java
(86%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/ScalingClusterAutoSwitchAlgorithm.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobAPIFactory.java
(51%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency}/DataCalculateParameter.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api}/check/consistency/DataConsistencyCheckResult.java
(95%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core/ingest/config
=> api/config/ingest}/DumperConfiguration.java (90%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core/ingest/config
=> api/config/ingest}/InventoryDumperConfiguration.java (95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/HandleConfiguration.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/ImporterConfiguration.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/JobConfiguration.java
(84%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/RuleConfiguration.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/TaskConfiguration.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/rulealtered}/WorkflowConfiguration.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/server}/ServerConfiguration.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/internal
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/datanode}/JobDataNodeEntry.java
(97%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/internal
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/datanode}/JobDataNodeLine.java
(97%)
rename
shardingsphere-kernel/{shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core
=>
shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api}/executor/AbstractLifecycleExecutor.java
(95%)
rename
shardingsphere-kernel/{shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core
=>
shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api}/executor/LifecycleExecutor.java
(93%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/channel/Channel.java (91%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/position/FinishedPosition.java (93%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/position/IngestPosition.java (92%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/position/PlaceholderPosition.java (94%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/position/PrimaryKeyPosition.java (96%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/Column.java (96%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/DataRecord.java (94%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/FinishedRecord.java (87%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/GroupedDataRecord.java (94%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/PlaceholderRecord.java (87%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> api}/ingest/record/Record.java (87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api}/job/JobStatus.java
(97%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api}/job/progress/JobProgress.java
(74%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/pojo}/DataConsistencyCheckAlgorithmInfo.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/pojo}/JobInfo.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/prepare/datasource}/ActualTableDefinition.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/prepare/datasource}/PrepareTargetTablesParameter.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/prepare/datasource}/TableDefinitionSQLType.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/task/progress}/IncrementalTaskDelay.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/task/progress}/IncrementalTaskProgress.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/task/progress}/InventoryTaskProgress.java
(78%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/progress/Progress.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/task/progress/TaskProgress.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline}/core/api/GovernanceRepositoryAPI.java
(89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/ScalingAPIFactory.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/PipelineAPIFactory.java
(81%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline}/core/api/impl/GovernanceRepositoryAPIImpl.java
(76%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingAPIImpl.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/api/impl/PipelineJobAPIImpl.java
(74%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency}/AbstractSingleTableDataCalculator.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/check/consistency/DataConsistencyChecker.java
(79%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/check/consistency/DataConsistencyCheckerImpl.java
(91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingDefaultDataConsistencyCheckAlgorithm.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/DefaultDataConsistencyCheckAlgorithm.java
(83%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency}/SingleTableDataCalculatorRegistry.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/check/source
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/datasource}/AbstractDataSourceChecker.java
(76%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/config/server}/yaml/ServerConfigurationYamlSwapper.java
(93%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/config/server}/yaml/YamlServerConfiguration.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/exception/DataCheckFailException.java
(94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/exception/ScalingJobCreationException.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineJobCreationException.java
(65%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/exception/ScalingTaskExecuteException.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineJobExecutionException.java
(71%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/exception/ScalingJobNotFoundException.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineJobNotFoundException.java
(79%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/exception/PrepareFailedException.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineJobPrepareFailedException.java
(73%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/exception/UnexpectedDataRecordOrderException.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute}/ExecuteCallback.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute}/ExecuteEngine.java
(97%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute}/FinishedCheckJobExecutor.java
(70%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/ScalingJobExecutor.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/execute/PipelineJobExecutor.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/importer/AbstractImporter.java
(81%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/importer/DataRecordMerger.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline}/core/job/FinishedCheckJob.java
(65%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline}/core/job/progress/yaml/JobProgressYamlSwapper.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline}/core/job/progress/yaml/YamlJobProgress.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer/splitter
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare}/InventoryTaskSplitter.java
(77%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/migration/common/job/preparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/prepare/datasource}/AbstractDataSourcePreparer.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core}/record/RecordUtil.java
(92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/sqlbuilder/AbstractScalingSQLBuilder.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/AbstractPipelineSQLBuilder.java
(93%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task}/IncrementalTask.java
(75%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task}/InventoryTask.java
(74%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTask.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTask.java
(74%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTaskFactory.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskFactory.java
(77%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingIdleClusterAutoSwitchAlgorithm.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/IdleRuleAlteredJobCompletionDetectAlgorithm.java
(81%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/config/ScalingContext.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredContext.java
(66%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/ScalingJob.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJob.java
(71%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/JobContext.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobContext.java
(68%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer/ScalingJobPreparer.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobPreparer.java
(71%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/util/ScalingTaskUtil.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobProgressDetector.java
(83%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/schedule/JobScheduler.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobScheduler.java
(71%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/schedule/JobSchedulerCenter.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobSchedulerCenter.java
(67%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/migration/common/api/ScalingWorker.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobWorker.java
(88%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/ScalingDataConsistencyCheckAlgorithm.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency/DataConsistencyCheckAlgorithm.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency}/SingleTableDataCalculator.java
(88%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/check/source
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/datasource}/DataSourceChecker.java
(93%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi}/importer/Importer.java
(85%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi}/importer/ImporterListener.java
(88%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> spi}/ingest/dumper/Dumper.java (81%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> spi}/ingest/dumper/IncrementalDumper.java (92%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> spi}/ingest/dumper/InventoryDumper.java (92%)
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/{core
=> spi}/ingest/position/PositionInitializer.java (91%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/rulealtered}/DataSourcePreparer.java
(86%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/rulealtered}/JobRuleAlteredDetector.java
(95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/api/ScalingClusterAutoSwitchAlgorithm.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/rulealtered/RuleAlteredJobCompletionDetectAlgorithm.java
(80%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/migration/common/spi/JobConfigurationPreparer.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/rulealtered/RuleAlteredJobConfigurationPreparer.java
(74%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common/sqlbuilder/ScalingSQLBuilder.java
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/sqlbuilder/PipelineSQLBuilder.java
(88%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/job/check/EnvironmentChecker.java
(86%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/job/check/EnvironmentCheckerFactory.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/scaling/core/job}/dumper/DumperFactory.java
(86%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/job/environment/ScalingEnvironmentManager.java
(87%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/scaling/core/job}/importer/ImporterFactory.java
(91%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/job/position/PositionInitializerFactory.java
(94%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/scaling/core/job}/sqlbuilder/ScalingSQLBuilderFactory.java
(87%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/spi/ScalingEntry.java
(79%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core}/src/main/java/org/apache/shardingsphere/scaling/core/spi/ScalingEntryLoader.java
(100%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.migration.common.spi.JobConfigurationPreparer
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.api.PipelineJobAPI
(91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.ScalingDataConsistencyCheckAlgorithm
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCheckAlgorithm
(88%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JobRuleAlteredDetector
=>
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.RuleAlteredJobCompletionDetectAlgorithm
(88%)
delete mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/pom.xml
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/progress/JobProgressTest.java
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.ScalingDataConsistencyCheckAlgorithm
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/{MySQLScalingSQLBuilder.java
=> MySQLPipelineSQLBuilder.java} (85%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/resources/META-INF/services/{org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator
=>
org.apache.shardingsphere.data.pipeline.spi.check.consistency.SingleTableDataCalculator}
(100%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/{MySQLScalingSQLBuilderTest.java
=> MySQLPipelineSQLBuilderTest.java} (84%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/component/{OpenGaussScalingSQLBuilder.java
=> OpenGaussPipelineSQLBuilder.java} (83%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/{PostgreSQLScalingSQLBuilder.java
=> PostgreSQLPipelineSQLBuilder.java} (76%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/resources/META-INF/services/{org.apache.shardingsphere.scaling.core.api.SingleTableDataCalculator
=>
org.apache.shardingsphere.data.pipeline.spi.check.consistency.SingleTableDataCalculator}
(100%)
rename
shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/component/{PostgreSQLScalingSQLBuilderTest.java
=> PostgreSQLPipelineSQLBuilderTest.java} (84%)
copy
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=> shardingsphere-test/shardingsphere-pipeline-test}/pom.xml (71%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/config
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/api/config/server}/yaml/ServerConfigurationYamlSwapperTest.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/config/internal
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/api/datanode}/JobDataNodeEntryTest.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/config/internal
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/api/datanode}/JobDataNodeLineTest.java
(96%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/api/impl/GovernanceRepositoryAPIImplTest.java
(69%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingAPIImplTest.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/api/impl/PipelineJobAPIImplTest.java
(65%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/check
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/check/consistency}/DataConsistencyCheckerImplTest.java
(81%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/check/consistency}/ScalingDefaultDataConsistencyCheckAlgorithmTest.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/check/consistency}/SingleTableDataCalculatorRegistryTest.java
(76%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/check
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/check/datasource}/AbstractDataSourceCheckerTest.java
(85%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/common
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core}/datasource/DataSourceManagerTest.java
(86%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/DataSourceWrapperTest.java
(100%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/datasource/MetaDataManagerTest.java
(100%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/engine
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/execute}/ExecuteEngineTest.java
(95%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/EmbedTestingServer.java
(98%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingFixtureDataConsistencyCheckAlgorithm.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureDataConsistencyCheckAlgorithm.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureDataSourceChecker.java
(90%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureDataSourcePreparer.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureEnvironmentChecker.java
(84%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture}/FixtureH2SingleTableDataCalculator.java
(79%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureImporter.java
(82%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureIncrementalDumper.java
(75%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureInventoryDumper.java
(90%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureSQLBuilder.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixturePipelineSQLBuilder.java
(77%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixturePositionInitializer.java
(83%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/fixture/FixtureClusterAutoSwitchAlgorithm.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureRuleAlteredJobCompletionDetectAlgorithm.java
(79%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/fixture/FixtureScalingEntry.java
(75%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core}/importer/AbstractImporterTest.java
(80%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core}/importer/DataRecordMergerTest.java
(96%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/MemoryChannelTest.java
(87%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/distribution/AutoAcknowledgeChannelTest.java
(91%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/distribution/DistributionChannelTest.java
(89%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/distribution/ManualBitSetTest.java
(100%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/position/PlaceholderPositionTest.java
(94%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/position/PrimaryKeyPositionTest.java
(95%)
rename
{shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core
=>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/record/DataRecordTest.java
(91%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/job/FinishedCheckJobTest.java
(75%)
create mode 100644
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/progress/JobProgressTest.java
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/preparer/splitter
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/prepare}/InventoryTaskSplitterTest.java
(91%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/migration/common/job/preparer
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/prepare/datasource}/AbstractDataSourcePreparerTest.java
(92%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/task/incremental
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/task}/IncrementalTaskTest.java
(64%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/task/inventory
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/task}/InventoryTaskTest.java
(77%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/core/util/ResourceUtil.java
(92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/api/impl/ScalingIdleClusterAutoSwitchAlgorithmTest.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/IdleRuleAlteredJobCompletionDetectAlgorithmTest.java
(54%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/ScalingJobTest.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/rulealtered/RuleAlteredJobTest.java
(68%)
rename
{shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline}/spi/ScalingEntryLoaderTest.java
(82%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/importer/AbstractSqlBuilderTest.java
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/spi/sqlbuilder/PipelineSQLBuilderTest.java
(67%)
copy
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JobRuleAlteredDetector
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCheckAlgorithm
(89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.api.ScalingClusterAutoSwitchAlgorithm
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.check.consistency.SingleTableDataCalculator
(89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JobRuleAlteredDetector
=>
shardingsphere-test/shardingsphere-pipeline-test/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.RuleAlteredJobCompletionDetectAlgorithm
(88%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/META-INF/services/org.apache.shardingsphere.scaling.core.spi.ScalingEntry
(91%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/config_sharding_sphere_jdbc_source.yaml
(100%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/config_sharding_sphere_jdbc_target.yaml
(100%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/config_standard_jdbc_target.yaml
(100%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/governance-repository.yaml
(100%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/job-progress.yaml
(100%)
rename {shardingsphere-scaling/shardingsphere-scaling-core =>
shardingsphere-test/shardingsphere-pipeline-test}/src/test/resources/logback-test.xml
(86%)
