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 7fda7a468b8 Refactor DatabaseTypedSPILoader (#26843)
add b31d6f8beaf Add IncrementalDumperCreator.createIncrementalDumper
(#26844)
No new revisions were added by this update.
Summary of changes:
.../infra/database/type/DatabaseTypeEngine.java | 17 ++++++++
.../database/type/DatabaseTypeEngineTest.java | 8 ++++
.../infra/util/close/QuietlyCloser.java | 8 ++--
.../ingest/dumper/IncrementalDumperCreator.java | 9 ++++
.../DefaultPipelineDataSourceManager.java | 3 --
.../datasource/PipelineDataSourceManager.java | 6 +--
.../pojo/DataConsistencyCheckAlgorithmInfo.java | 3 +-
.../pipeline/common/util/DatabaseTypeUtils.java | 51 ----------------------
...SingleTableInventoryDataConsistencyChecker.java | 6 +--
...RC32MatchDataConsistencyCalculateAlgorithm.java | 7 ++-
.../DataConsistencyCalculateAlgorithm.java | 3 +-
...DataMatchDataConsistencyCalculateAlgorithm.java | 20 ++++-----
.../importer/SingleChannelConsumerImporter.java | 4 +-
.../pipeline/core/job/AbstractPipelineJob.java | 4 +-
.../AbstractInventoryIncrementalJobAPIImpl.java | 7 +--
.../core/preparer/PipelineJobPreparerUtils.java | 6 +--
.../runner/InventoryIncrementalTasksRunner.java | 6 +--
.../common/util/DatabaseTypeUtilsTest.java | 38 ----------------
.../consistencycheck => dialect/h2}/pom.xml | 4 +-
.../pipeline/h2/H2IncrementalDumperCreator.java} | 16 ++++---
...line.spi.ingest.dumper.IncrementalDumperCreator | 3 +-
.../mysql/MySQLIncrementalDumperCreator.java | 2 +-
kernel/data-pipeline/dialect/pom.xml | 1 +
.../ShowMigrationCheckAlgorithmsExecutor.java | 6 ++-
.../data/pipeline/cdc/api/impl/CDCJobAPI.java | 9 ++--
.../data/pipeline/cdc/core/job/CDCJob.java | 4 +-
.../pipeline/cdc/core/task/CDCTasksRunner.java | 6 +--
.../DataConsistencyCalculateAlgorithmFixture.java | 5 +--
28 files changed, 97 insertions(+), 165 deletions(-)
rename
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/util/CloseUtils.java
=>
infra/util/src/main/java/org/apache/shardingsphere/infra/util/close/QuietlyCloser.java
(86%)
delete mode 100644
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/util/DatabaseTypeUtils.java
delete mode 100644
kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/common/util/DatabaseTypeUtilsTest.java
copy kernel/data-pipeline/{scenario/consistencycheck => dialect/h2}/pom.xml
(90%)
copy
kernel/data-pipeline/dialect/{mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/MySQLIncrementalDumperCreator.java
=>
h2/src/main/java/org/apache/shardingsphere/data/pipeline/h2/H2IncrementalDumperCreator.java}
(81%)
copy examples/docker/shardingsphere-proxy/governance/stop.sh =>
kernel/data-pipeline/dialect/h2/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.ingest.dumper.IncrementalDumperCreator
(91%)
