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 1329c26 [BEAM-8624] Implement Worker Status FnService in Dataflow
runner (#10115)
add 217afd5 [BEAM-5605] Add support for executing pair with restriction,
split restriction, split and size restriction, process element and restriction
and process sized element and restriction within the Java SDK harness. (#10535)
No new revisions were added by this update.
Summary of changes:
.../core/construction/ParDoTranslation.java | 21 +-
sdks/java/harness/build.gradle | 1 +
.../fn/harness/DoFnPTransformRunnerFactory.java | 300 ----------
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 602 ++++++++++++++++++++-
.../harness/SplittableProcessElementsRunner.java | 282 ----------
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 359 +++++++++++-
6 files changed, 955 insertions(+), 610 deletions(-)
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/DoFnPTransformRunnerFactory.java
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableProcessElementsRunner.java
