This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 16db153 Merge pull request #6168 from
amaliujia/rui_wang-test_math_function
add b47133f Added maxPublishBatchSize parameter to PubsubBoundedWriter
class.
add fa2d110 updated BoundedPubsubWriter to dynamically flush if queued
messages exceed a pre-defined maximum batch byte size
add 9899d8a updated UnboundedPubsubSink to accept new parameters.
add c83e853 Resolve merging conflicts
add 806fa19 set maximum batch size to 10mb (10 * 1024 * 1024)
new ec3ed84 Merge pull request #3619: [BEAM-2660] Set PubsubIO batch size
using builder
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 94 ++++++++++++++++++++--
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 23 +++++-
2 files changed, 107 insertions(+), 10 deletions(-)
