[shardingsphere] branch master updated (1aea274bba7 -> d3b5a1ac859)

[pa...@apache.org]

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 1aea274bba7 Remove useless getter (#23085)
     add d3b5a1ac859 Clean pipeline API (#23084)

No new revisions were added by this update.

Summary of changes:
 .../pipeline/api/ConsistencyCheckJobPublicAPI.java | 78 ---------------------
 .../api/InventoryIncrementalJobPublicAPI.java      | 79 ----------------------
 .../data/pipeline/api/MigrationJobPublicAPI.java   | 62 -----------------
 .../data/pipeline/api/PipelineJobPublicAPI.java    | 57 ----------------
 .../pipeline/api/PipelineJobPublicAPIFactory.java  | 62 -----------------
 .../core/api/InventoryIncrementalJobAPI.java       | 50 ++++++++++++++
 .../data/pipeline/core/api/PipelineAPIFactory.java | 12 ----
 .../data/pipeline/core/api/PipelineJobAPI.java     | 34 +++++++++-
 .../PipelineJobAPIFactory.java}                    | 26 ++++---
 .../AbstractInventoryIncrementalJobAPIImpl.java    |  5 +-
 .../core/api/impl/AbstractPipelineJobAPIImpl.java  |  2 +-
 .../pipeline/core/job/AbstractPipelineJob.java     |  6 +-
 .../persist/PipelineJobProgressPersistService.java |  4 +-
 .../core/task/InventoryIncrementalTasksRunner.java |  6 +-
 kernel/data-pipeline/distsql/handler/pom.xml       |  7 +-
 .../ShowMigrationCheckAlgorithmsResultSet.java     | 10 +--
 .../query/ShowMigrationCheckStatusResultSet.java   |  7 +-
 .../query/ShowMigrationJobStatusResultSet.java     | 10 +--
 .../handler/query/ShowMigrationListResultSet.java  |  7 +-
 .../ShowMigrationSourceStorageUnitsResultSet.java  |  7 +-
 .../handler/update/CheckMigrationJobUpdater.java   |  9 ++-
 .../handler/update/CommitMigrationUpdater.java     | 10 +--
 .../handler/update/DropMigrationCheckUpdater.java  |  5 +-
 .../handler/update/MigrateTableUpdater.java        |  7 +-
 .../RegisterMigrationSourceStorageUnitUpdater.java |  7 +-
 .../handler/update/RollbackMigrationUpdater.java   | 10 +--
 .../handler/update/StartMigrationCheckUpdater.java |  7 +-
 .../handler/update/StartMigrationUpdater.java      |  7 +-
 .../handler/update/StopMigrationCheckUpdater.java  |  7 +-
 .../handler/update/StopMigrationUpdater.java       |  7 +-
 ...nregisterMigrationSourceStorageUnitUpdater.java |  7 +-
 ...hardingsphere.distsql.handler.update.RALUpdater |  1 +
 .../api/ConsistencyCheckJobAPI.java                | 27 --------
 .../api/ConsistencyCheckJobAPIFactory.java         | 40 -----------
 ...JobAPIImpl.java => ConsistencyCheckJobAPI.java} | 47 ++++++++++---
 .../task/ConsistencyCheckTasksRunner.java          | 10 +--
 ....data.pipeline.api.ConsistencyCheckJobPublicAPI | 18 -----
 ...ingsphere.data.pipeline.core.api.PipelineJobAPI |  2 +-
 ...rio.consistencycheck.api.ConsistencyCheckJobAPI | 18 -----
 .../pipeline/scenario/migration/MigrationJob.java  |  5 +-
 .../scenario/migration/api/MigrationJobAPI.java    | 44 ------------
 .../migration/api/MigrationJobAPIFactory.java      | 40 -----------
 ...grationJobAPIImpl.java => MigrationJobAPI.java} | 35 +++++++---
 .../MigrationDataConsistencyChecker.java           |  4 +-
 .../migration/prepare/MigrationJobPreparer.java    | 15 ++--
 ...a.pipeline.api.InventoryIncrementalJobPublicAPI | 18 -----
 ...gsphere.data.pipeline.api.MigrationJobPublicAPI | 18 -----
 ...ingsphere.data.pipeline.core.api.PipelineJobAPI |  2 +-
 ...pipeline.scenario.migration.api.MigrationJobAPI | 18 -----
 .../ral/queryable/ShowMigrationRuleResultSet.java  | 12 ++--
 .../AlterInventoryIncrementalRuleUpdater.java      |  8 +--
 .../handler/cdc/fixture/FixtureCDCJobAPI.java      | 31 +++++++++
 ...oryTest.java => PipelineJobAPIFactoryTest.java} | 16 +++--
 .../api/PipelineJobPublicAPIFactoryTest.java       | 56 ---------------
 ...plTest.java => ConsistencyCheckJobAPITest.java} | 16 ++---
 ...obAPIImplTest.java => MigrationJobAPITest.java} | 11 ++-
 .../core/util/JobConfigurationBuilder.java         |  8 +--
 .../pipeline/core/util/PipelineContextUtil.java    |  4 +-
 .../impl/ConsistencyCheckJobAPIFactoryTest.java    | 33 ---------
 .../api/impl/MigrationJobAPIFactoryTest.java       | 33 ---------
 .../pipeline/src/test/resources/logback-test.xml   |  2 +-
 61 files changed, 324 insertions(+), 882 deletions(-)
 delete mode 100644 kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ConsistencyCheckJobPublicAPI.java
 delete mode 100644 kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/InventoryIncrementalJobPublicAPI.java
 delete mode 100644 kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/MigrationJobPublicAPI.java
 delete mode 100644 kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPI.java
 delete mode 100644 kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/PipelineJobPublicAPIFactory.java
 copy kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/{metadata/node/event/handler/PipelineChangedJobConfigurationProcessorFactory.java => api/PipelineJobAPIFactory.java} (62%)
 delete mode 100644 kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/api/ConsistencyCheckJobAPI.java
 delete mode 100644 kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/api/ConsistencyCheckJobAPIFactory.java
 rename kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/api/impl/{ConsistencyCheckJobAPIImpl.java => ConsistencyCheckJobAPI.java} (93%)
 delete mode 100644 kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.api.ConsistencyCheckJobPublicAPI
 delete mode 100644 kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI
 delete mode 100644 kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
 delete mode 100644 kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPIFactory.java
 rename kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/impl/{MigrationJobAPIImpl.java => MigrationJobAPI.java} (97%)
 delete mode 100644 kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.api.InventoryIncrementalJobPublicAPI
 delete mode 100644 kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.api.MigrationJobPublicAPI
 delete mode 100644 kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI
 rename test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/api/{PipelineAPIFactoryTest.java => PipelineJobAPIFactoryTest.java} (67%)
 delete mode 100644 test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/api/PipelineJobPublicAPIFactoryTest.java
 rename test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/api/impl/{ConsistencyCheckJobAPIImplTest.java => ConsistencyCheckJobAPITest.java} (94%)
 rename test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/api/impl/{MigrationJobAPIImplTest.java => MigrationJobAPITest.java} (98%)
 delete mode 100644 test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/scenario/consistencycheck/api/impl/ConsistencyCheckJobAPIFactoryTest.java
 delete mode 100644 test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/scenario/migration/api/impl/MigrationJobAPIFactoryTest.java