You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by pa...@apache.org on 2022/01/29 03:53:07 UTC
[shardingsphere] branch master updated (c1a6ad6 -> 7aee905)
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 c1a6ad6 For #15136: isUncompletedJobOfSameSchemaInJobList method ignore completed job (#15172)
add 7aee905 Refactor to use unified PipelineTableMetaDataLoader in scaling (#15161)
No new revisions were added by this update.
Summary of changes:
.../core/datasource/PipelineMetaDataManager.java | 60 -------------
.../ingest/dumper/AbstractInventoryDumper.java | 14 +--
.../loader/PipelineTableMetaDataLoader.java | 52 ++++++++---
.../metadata/model/PipelineColumnMetaData.java | 11 ++-
.../core/metadata/model/PipelineTableMetaData.java | 49 ++++++++--
.../rulealtered/prepare/InventoryTaskSplitter.java | 30 +++----
.../mysql/ingest/MySQLIncrementalDumper.java | 33 +++----
.../column/metadata/MySQLColumnMetaData.java | 39 --------
.../column/metadata/MySQLColumnMetaDataLoader.java | 100 ---------------------
.../postgresql/ingest/wal/WalEventConverter.java | 27 +++---
.../loader/PipelineTableMetaDataLoaderTest.java} | 39 ++++----
11 files changed, 164 insertions(+), 290 deletions(-)
delete mode 100644 shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/datasource/PipelineMetaDataManager.java
delete mode 100644 shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/column/metadata/MySQLColumnMetaData.java
delete mode 100644 shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-dialect/shardingsphere-data-pipeline-mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/column/metadata/MySQLColumnMetaDataLoader.java
rename shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/{datasource/PipelineMetaDataManagerTest.java => metadata/loader/PipelineTableMetaDataLoaderTest.java} (71%)