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 324cf7d Minor: Fix doc left nav on dev website (#14881)
add 715de1b GroupIntoBatches improvements
add 6e95bc9 make sure that DataflowRunner batch override for
GroupIntoBatches handles byte-size splitting
add fe88aaf fix DataflowRunnerTest
add 3115cf7 Merge pull request #14852: [BEAM-12378] GroupIntoBatches
improvements
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 5 +-
.../construction/GroupIntoBatchesTranslation.java | 1 +
.../GroupIntoBatchesTranslationTest.java | 6 +-
.../runners/dataflow/GroupIntoBatchesOverride.java | 59 +++--
.../beam/runners/dataflow/DataflowRunnerTest.java | 169 +++++++++++---
.../beam/sdk/transforms/GroupIntoBatches.java | 251 +++++++++++++++------
.../beam/sdk/transforms/GroupIntoBatchesTest.java | 96 +++++++-
7 files changed, 470 insertions(+), 117 deletions(-)
