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 <k...@google.com> Authored: Fri Nov 18 14:20:21 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------