beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [07/50] incubator-beam git commit: This closes #1141
Date Tue, 25 Oct 2016 16:28:25 GMT
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/apex-runner
Commit: 153351126357da91d7adeab8339025914e18920c
Parents: 465c7d1 5226461
Author: Kenneth Knowles <klk@google.com>
Authored: Thu Oct 20 19:52:50 2016 -0700
Committer: Kenneth Knowles <klk@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
----------------------------------------------------------------------


Mime
View raw message