This closes #1049
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03b89c06 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/03b89c06 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/03b89c06 Branch: refs/heads/master Commit: 03b89c065aa7a0a6d86aeb105dc9164f071e28a5 Parents: 9b71f16 e2a24f3 Author: Kenneth Knowles <[email protected]> Authored: Thu Oct 6 20:18:33 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Oct 6 20:18:33 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/transforms/DoFn.java | 40 ++++++ .../beam/sdk/transforms/DoFnAdapters.java | 142 ++++++++++++++++++- .../sdk/transforms/reflect/DoFnInvokers.java | 86 +++++++++++ .../transforms/reflect/DoFnInvokersTest.java | 46 ++++++ .../transforms/DoFnInvokersBenchmark.java | 7 + 5 files changed, 318 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
