This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c9e5ea8 [BEAM -7741] Implement SetState for Python SDK (#9090)
add 57d8fd3 [BEAM-7912] Optimize GroupIntoBatches for batch Dataflow
pipelines.
add 7848ead [BEAM-7912] Optimize GroupIntoBatches for batch Dataflow
pipelines.
No new revisions were added by this update.
Summary of changes:
runners/google-cloud-dataflow-java/build.gradle | 20 ++++---
.../beam/runners/dataflow/DataflowRunner.java | 69 ++++++++++++++++++++++
.../beam/runners/dataflow/DataflowRunnerTest.java | 63 +++++++++++++++++++-
.../beam/sdk/transforms/GroupIntoBatches.java | 5 ++
4 files changed, 148 insertions(+), 9 deletions(-)
