Closes #812
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/89367cfb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/89367cfb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/89367cfb Branch: refs/heads/master Commit: 89367cfb19ae86d66441970277177512961d3b6a Parents: 4609773 fbf77f9 Author: bchambers <[email protected]> Authored: Wed Aug 17 15:43:47 2016 -0700 Committer: bchambers <[email protected]> Committed: Wed Aug 17 15:43:47 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/transforms/DoFn.java | 17 +- .../beam/sdk/transforms/DoFnAdapters.java | 281 +++++ .../beam/sdk/transforms/DoFnReflector.java | 1150 ------------------ .../apache/beam/sdk/transforms/DoFnTester.java | 2 +- .../org/apache/beam/sdk/transforms/ParDo.java | 6 +- .../sdk/transforms/reflect/DoFnInvoker.java | 61 + .../sdk/transforms/reflect/DoFnInvokers.java | 506 ++++++++ .../sdk/transforms/reflect/DoFnSignature.java | 113 ++ .../sdk/transforms/reflect/DoFnSignatures.java | 321 +++++ .../sdk/transforms/reflect/package-info.java | 23 + .../beam/sdk/transforms/DoFnReflectorTest.java | 822 ------------- .../apache/beam/sdk/transforms/FlattenTest.java | 4 +- .../dofnreflector/DoFnReflectorTestHelper.java | 116 -- .../transforms/reflect/DoFnInvokersTest.java | 498 ++++++++ .../reflect/DoFnInvokersTestHelper.java | 116 ++ .../transforms/reflect/DoFnSignaturesTest.java | 371 ++++++ .../transforms/DoFnInvokersBenchmark.java | 224 ++++ .../transforms/DoFnReflectorBenchmark.java | 232 ---- 18 files changed, 2529 insertions(+), 2334 deletions(-) ----------------------------------------------------------------------
