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/11/18 22:20:42 UTC

[2/2] incubator-beam git commit: This closes #1386

This closes #1386


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2a7169b6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2a7169b6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2a7169b6

Branch: refs/heads/master
Commit: 2a7169b6f62de765fe1e4b28bad195f5e102aec7
Parents: bb9c386 33fb8c2
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri Nov 18 14:20:21 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri Nov 18 14:20:21 2016 -0800

----------------------------------------------------------------------
 .../beam/runners/core/SimpleDoFnRunner.java     |   4 +-
 .../beam/runners/core/SplittableParDo.java      |   7 +-
 .../org/apache/beam/sdk/transforms/DoFn.java    | 122 -------------------
 .../beam/sdk/transforms/DoFnAdapters.java       |  10 +-
 .../reflect/ByteBuddyDoFnInvokerFactory.java    |  41 +++----
 .../sdk/transforms/reflect/DoFnInvoker.java     | 121 +++++++++++++++++-
 .../sdk/transforms/reflect/DoFnInvokers.java    |   4 +-
 .../sdk/transforms/reflect/OnTimerInvoker.java  |   8 +-
 .../transforms/reflect/DoFnInvokersTest.java    |   5 +-
 .../transforms/reflect/OnTimerInvokersTest.java |   2 +-
 .../transforms/DoFnInvokersBenchmark.java       |   5 +-
 11 files changed, 161 insertions(+), 168 deletions(-)
----------------------------------------------------------------------