You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/07/18 20:05:37 UTC
[4/4] beam git commit: This closes #3577: Fix split package in SDK
harness
This closes #3577: Fix split package in SDK harness
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c2d8a35
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c2d8a35
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2c2d8a35
Branch: refs/heads/master
Commit: 2c2d8a35f154a6c5615917a859f58f8fcf7f2789
Parents: 5a0b74c f1b4700
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Jul 18 12:52:32 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Jul 18 12:52:32 2017 -0700
----------------------------------------------------------------------
.../beam/fn/harness/BeamFnDataReadRunner.java | 173 ++++++
.../beam/fn/harness/BeamFnDataWriteRunner.java | 159 ++++++
.../beam/fn/harness/BoundedSourceRunner.java | 167 ++++++
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 548 +++++++++++++++++++
.../fn/harness/PTransformRunnerFactory.java | 81 +++
.../harness/control/ProcessBundleHandler.java | 4 +-
.../beam/runners/core/BeamFnDataReadRunner.java | 173 ------
.../runners/core/BeamFnDataWriteRunner.java | 159 ------
.../beam/runners/core/BoundedSourceRunner.java | 167 ------
.../beam/runners/core/FnApiDoFnRunner.java | 547 ------------------
.../runners/core/PTransformRunnerFactory.java | 81 ---
.../apache/beam/runners/core/package-info.java | 22 -
.../fn/harness/BeamFnDataReadRunnerTest.java | 281 ++++++++++
.../fn/harness/BeamFnDataWriteRunnerTest.java | 269 +++++++++
.../fn/harness/BoundedSourceRunnerTest.java | 187 +++++++
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 210 +++++++
.../control/ProcessBundleHandlerTest.java | 2 +-
.../runners/core/BeamFnDataReadRunnerTest.java | 281 ----------
.../runners/core/BeamFnDataWriteRunnerTest.java | 269 ---------
.../runners/core/BoundedSourceRunnerTest.java | 187 -------
.../beam/runners/core/FnApiDoFnRunnerTest.java | 210 -------
21 files changed, 2078 insertions(+), 2099 deletions(-)
----------------------------------------------------------------------