This closes #1309
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3f8db06b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3f8db06b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3f8db06b Branch: refs/heads/master Commit: 3f8db06bd2d35ea736d7c51df2c114f5cf4127f4 Parents: f7745dc 14a71e4 Author: Kenneth Knowles <[email protected]> Authored: Thu Nov 10 14:18:08 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Thu Nov 10 14:18:08 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/core/SimpleDoFnRunner.java | 4 +- .../beam/runners/core/SplittableParDo.java | 12 +- .../runners/direct/DoFnLifecycleManager.java | 4 +- .../runners/direct/ParDoOverrideFactory.java | 2 +- .../beam/sdk/transforms/DoFnAdapters.java | 6 +- .../org/apache/beam/sdk/transforms/ParDo.java | 6 +- .../reflect/ByteBuddyDoFnInvokerFactory.java | 828 +++++++++++++++++++ .../reflect/ByteBuddyOnTimerInvokerFactory.java | 279 +++++++ .../transforms/reflect/DoFnInvokerFactory.java | 27 + .../sdk/transforms/reflect/DoFnInvokers.java | 711 +--------------- .../sdk/transforms/reflect/DoFnSignatures.java | 11 +- .../reflect/OnTimerInvokerFactory.java | 36 + .../sdk/transforms/reflect/OnTimerInvokers.java | 243 +----- .../transforms/reflect/DoFnInvokersTest.java | 24 +- .../DoFnSignaturesProcessElementTest.java | 12 +- .../DoFnSignaturesSplittableDoFnTest.java | 34 +- .../transforms/reflect/DoFnSignaturesTest.java | 66 +- .../transforms/reflect/OnTimerInvokersTest.java | 2 +- .../transforms/DoFnInvokersBenchmark.java | 2 +- 19 files changed, 1295 insertions(+), 1014 deletions(-) ----------------------------------------------------------------------
