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 8e81dfa [BEAM-10329] Change dataflow runner
BatchStatefulParDoOverrides to use reshuffle for (#12096)
add 1d189e5 [BEAM-10303] Add support for the non-window observing
optimization to DoFn execution in portable Beam Java (#12093)
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/transforms/reflect/DoFnSignature.java | 36 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 580 ++++++++++++++-------
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 457 +++++++++++++++-
3 files changed, 847 insertions(+), 226 deletions(-)
