This closes #1282
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9de9ce69 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9de9ce69 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9de9ce69 Branch: refs/heads/master Commit: 9de9ce69fa010f46911ac0f9cfbe4df2e475772b Parents: ac252a7 9c3e59f Author: Kenneth Knowles <[email protected]> Authored: Mon Nov 7 15:25:04 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Mon Nov 7 15:25:04 2016 -0800 ---------------------------------------------------------------------- .../beam/runners/core/SimpleDoFnRunner.java | 12 ++ .../beam/runners/core/SplittableParDo.java | 12 ++ .../org/apache/beam/sdk/transforms/DoFn.java | 20 +++ .../beam/sdk/transforms/DoFnAdapters.java | 22 +++ .../org/apache/beam/sdk/transforms/ParDo.java | 43 +++++- .../sdk/transforms/reflect/DoFnInvokers.java | 143 +++++++++++++------ .../sdk/transforms/reflect/DoFnSignature.java | 67 ++++++--- .../sdk/transforms/reflect/DoFnSignatures.java | 56 +++++++- .../beam/sdk/transforms/windowing/WindowFn.java | 12 ++ .../apache/beam/sdk/transforms/ParDoTest.java | 61 ++++++++ .../transforms/reflect/DoFnInvokersTest.java | 100 ++++++++----- .../DoFnSignaturesSplittableDoFnTest.java | 5 +- .../transforms/reflect/DoFnSignaturesTest.java | 3 +- 13 files changed, 445 insertions(+), 111 deletions(-) ----------------------------------------------------------------------
