This is an automated email from the ASF dual-hosted git repository.
udim pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 735db24 [BEAM-13140] Fixes bug in WriteRename class
add 0d172c3 Performance improvement to PubSubLiteIO to not use a
streaming committer to send one commit message.
add beac28d Merge pull request #15880: Performance improvement to
PubSubLiteIO to not use a streaming committer to send one commit message
No new revisions were added by this update.
Summary of changes:
...nitialOffsetReader.java => BlockingCommitter.java} | 8 ++------
.../internal/PerSubscriptionPartitionSdf.java | 14 ++++----------
.../gcp/pubsublite/internal/SubscribeTransform.java | 3 +--
.../gcp/pubsublite/internal/SubscriberAssembler.java | 19 ++++++++++---------
.../internal/PerSubscriptionPartitionSdfTest.java | 16 +++-------------
5 files changed, 20 insertions(+), 40 deletions(-)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/{InitialOffsetReader.java
=> BlockingCommitter.java} (84%)
