[beam] branch master updated (16db153 -> ec3ed84)

[re...@apache.org]

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(-)

[beam] 01/01: Merge pull request #3619: [BEAM-2660] Set PubsubIO batch size using builder

[re...@apache.org]

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

reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit ec3ed8452b66d6decb5e1c0790ae42eef54f2831
Merge: 16db153 806fa19
Author: reuvenlax <re...@google.com>
AuthorDate: Thu Aug 9 11:41:32 2018 -0700

    Merge pull request #3619: [BEAM-2660] Set PubsubIO batch size using builder

 .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java    | 94 ++++++++++++++++++++--
 .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java     | 23 +++++-
 2 files changed, 107 insertions(+), 10 deletions(-)