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 2021/10/14 19:17:57 UTC
[beam] branch master updated (0b1931c -> e290c08)
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 0b1931c [Go SDK] Small typo fixes. (#15725)
add e290c08 [BEAM-13038] Migrate to use a context object within PTransformRunnerFactory. (#15711)
No new revisions were added by this update.
Summary of changes:
.../beam/fn/harness/BeamFnDataReadRunner.java | 53 +-
.../beam/fn/harness/BeamFnDataWriteRunner.java | 51 +-
.../org/apache/beam/fn/harness/CombineRunners.java | 60 +-
.../org/apache/beam/fn/harness/FlattenRunner.java | 49 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 92 +-
.../org/apache/beam/fn/harness/MapFnRunners.java | 51 +-
.../beam/fn/harness/PTransformRunnerFactory.java | 156 +--
.../fn/harness/control/ProcessBundleHandler.java | 143 ++-
.../harness/data/PCollectionConsumerRegistry.java | 9 -
.../beam/fn/harness/AssignWindowsRunnerTest.java | 66 +-
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 123 +--
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 63 +-
.../apache/beam/fn/harness/CombineRunnersTest.java | 301 ++---
.../apache/beam/fn/harness/FlattenRunnerTest.java | 113 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 1158 +++++++-------------
.../apache/beam/fn/harness/MapFnRunnersTest.java | 181 +--
.../PTransformRunnerFactoryTestContext.java | 258 +++++
.../harness/control/ProcessBundleHandlerTest.java | 235 +---
18 files changed, 1207 insertions(+), 1955 deletions(-)
create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/PTransformRunnerFactoryTestContext.java