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/21 23:09:59 UTC
[shardingsphere] branch master updated (726494b -> 1e6268a)
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 726494b Add unit tests about PostgreSQL batched inserts (#14985)
add 1e6268a Rename and move PipelineChannel memory impl (#14990)
No new revisions were added by this update.
Summary of changes:
.../channel/{distribution => memory}/ManualBitSet.java | 2 +-
.../MultiplexMemoryPipelineChannel.java} | 15 +++++++--------
.../SimpleMemoryPipelineChannel.java} | 11 +++++------
.../spi/ingest/channel/MemoryPipelineChannelFactory.java | 4 ++--
.../pipeline/mysql/ingest/MySQLIncrementalDumperTest.java | 6 +++---
.../postgresql/ingest/PostgreSQLWalDumperTest.java | 6 +++---
.../{distribution => memory}/ManualBitSetTest.java | 2 +-
.../MultiplexMemoryPipelineChannelTest.java} | 8 ++++----
8 files changed, 26 insertions(+), 28 deletions(-)
rename shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/{distribution => memory}/ManualBitSet.java (99%)
rename shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/{distribution/MemoryPipelineChannel.java => memory/MultiplexMemoryPipelineChannel.java} (88%)
rename shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/{distribution/BlockingQueueChannel.java => memory/SimpleMemoryPipelineChannel.java} (90%)
rename shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/{distribution => memory}/ManualBitSetTest.java (99%)
rename shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/ingest/channel/{distribution/MemoryPipelineChannelTest.java => memory/MultiplexMemoryPipelineChannelTest.java} (93%)