This closes #1528
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77295944 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77295944 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/77295944 Branch: refs/heads/master Commit: 772959447a24737956ec7142f6f157807d877d64 Parents: 6807480 a26ed13 Author: Kenneth Knowles <[email protected]> Authored: Wed Dec 7 19:22:44 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Wed Dec 7 19:22:44 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/core/SimpleDoFnRunner.java | 13 +++ .../beam/runners/core/SplittableParDo.java | 5 ++ .../org/apache/beam/sdk/transforms/DoFn.java | 22 +++++ .../beam/sdk/transforms/DoFnAdapters.java | 12 +++ .../apache/beam/sdk/transforms/DoFnTester.java | 7 ++ .../reflect/ByteBuddyDoFnInvokerFactory.java | 11 +++ .../sdk/transforms/reflect/DoFnInvoker.java | 8 ++ .../sdk/transforms/reflect/DoFnSignature.java | 26 +++++- .../sdk/transforms/reflect/DoFnSignatures.java | 90 ++++++++++++++++---- .../DoFnSignaturesSplittableDoFnTest.java | 3 +- .../transforms/reflect/DoFnSignaturesTest.java | 47 ++++++++++ 11 files changed, 226 insertions(+), 18 deletions(-) ----------------------------------------------------------------------
