You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by me...@apache.org on 2022/01/25 07:12:38 UTC
[shardingsphere] branch master updated (35d63d1 -> 6c68a7c)

This is an automated email from the ASF dual-hosted git repository.

menghaoran pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.


    from 35d63d1  For #14952,add unit test. (#15031)
     add 6c68a7c  Remove Dumper.setChannel and Importer.setChannel, make channel final in impl (#15040)

No new revisions were added by this update.

Summary of changes:
 .../pipeline/core/importer/AbstractImporter.java   |  7 ++--
 .../core/ingest/channel/EmptyAckCallback.java}     | 16 ++++------
 .../memory/MultiplexMemoryPipelineChannel.java     |  7 ++++
 .../memory/SimpleMemoryPipelineChannel.java        |  7 ++++
 .../ingest/dumper/AbstractIncrementalDumper.java   | 28 ++++++----------
 .../ingest/dumper/AbstractInventoryDumper.java     |  7 ++--
 .../data/pipeline/core/task/IncrementalTask.java   | 16 +++-------
 .../data/pipeline/core/task/InventoryTask.java     | 10 ++----
 .../scaling/core/job/dumper/DumperFactory.java     | 37 ++++++++++------------
 .../scaling/core/job/importer/ImporterFactory.java | 28 +++++++---------
 .../pipeline/mysql/importer/MySQLImporter.java     |  5 +--
 .../mysql/ingest/MySQLIncrementalDumper.java       | 13 ++++----
 .../mysql/ingest/MySQLInventoryDumper.java         |  5 +--
 .../pipeline/mysql/importer/MySQLImporterTest.java |  6 +++-
 .../mysql/ingest/MySQLIncrementalDumperTest.java   |  5 ++-
 .../pipeline/mysql/ingest/MySQLJdbcDumperTest.java |  3 +-
 .../opengauss/importer/OpenGaussImporter.java      |  5 +--
 .../opengauss/ingest/OpenGaussWalDumper.java       |  7 ++--
 .../postgresql/importer/PostgreSQLImporter.java    |  5 +--
 .../ingest/PostgreSQLInventoryDumper.java          |  5 +--
 .../postgresql/ingest/PostgreSQLWalDumper.java     | 13 ++++----
 .../importer/PostgreSQLImporterTest.java           |  6 +++-
 .../ingest/PostgreSQLJdbcDumperTest.java           |  3 +-
 .../postgresql/ingest/PostgreSQLWalDumperTest.java |  6 ++--
 .../data/pipeline/spi/importer/Importer.java       |  8 -----
 .../data/pipeline/spi/ingest/dumper/Dumper.java    |  8 -----
 .../pipeline/core/fixture/FixtureImporter.java     |  6 +---
 .../core/fixture/FixtureIncrementalDumper.java     | 16 +++-------
 .../core/fixture/FixtureInventoryDumper.java       |  5 +--
 .../core/importer/AbstractImporterTest.java        |  3 +-
 30 files changed, 128 insertions(+), 168 deletions(-)
 copy shardingsphere-kernel/shardingsphere-data-pipeline/{shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/channel/AckCallback.java => shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/EmptyAckCallback.java} (73%)
 copy shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureIncrementalDumper.java => shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/AbstractIncrementalDumper.java (69%)