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 2016/10/21 02:53:15 UTC
[7/7] incubator-beam git commit: This closes #1141
This closes #1141
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/15335112
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/15335112
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/15335112
Branch: refs/heads/master
Commit: 153351126357da91d7adeab8339025914e18920c
Parents: 465c7d1 5226461
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 20 19:52:50 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Oct 20 19:52:50 2016 -0700
----------------------------------------------------------------------
.../apache/beam/runners/core/DoFnRunners.java | 189 +++++--
.../beam/runners/core/SimpleDoFnRunner.java | 337 +++++++-----
.../beam/runners/core/SimpleOldDoFnRunner.java | 521 +++++++++++++++++++
.../beam/runners/core/SimpleDoFnRunnerTest.java | 88 ----
.../runners/core/SimpleOldDoFnRunnerTest.java | 88 ++++
.../beam/runners/direct/ParDoEvaluator.java | 3 +-
.../org/apache/beam/sdk/transforms/OldDoFn.java | 183 +++++++
.../org/apache/beam/sdk/transforms/ParDo.java | 248 +++++----
8 files changed, 1299 insertions(+), 358 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/15335112/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/15335112/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/OldDoFn.java
----------------------------------------------------------------------