You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/01/10 19:08:10 UTC
[beam] branch master updated (1329c26 -> 217afd5)
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