Closes #896
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13b45895 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13b45895 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/13b45895 Branch: refs/heads/master Commit: 13b45895eb13cd48557472463404bd097d7097d7 Parents: a5d1293 a0a2488 Author: bchambers <bchamb...@google.com> Authored: Wed Oct 12 17:29:21 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Oct 12 17:29:21 2016 -0700 ---------------------------------------------------------------------- runners/core-java/pom.xml | 6 + .../runners/core/ElementAndRestriction.java | 42 ++ .../core/ElementAndRestrictionCoder.java | 67 +++ .../runners/core/GBKIntoKeyedWorkItems.java | 40 ++ .../beam/runners/core/SplittableParDo.java | 469 ++++++++++++++++ .../core/ElementAndRestrictionCoderTest.java | 127 +++++ .../beam/runners/core/SplittableParDoTest.java | 467 ++++++++++++++++ ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 66 +++ .../beam/runners/direct/DirectRunner.java | 5 + .../runners/direct/ParDoOverrideFactory.java | 55 ++ .../beam/runners/direct/SplittableDoFnTest.java | 225 ++++++++ .../beam/sdk/annotations/Experimental.java | 8 +- .../org/apache/beam/sdk/transforms/DoFn.java | 218 +++++++- .../beam/sdk/transforms/DoFnAdapters.java | 27 +- .../apache/beam/sdk/transforms/DoFnTester.java | 117 ++-- .../org/apache/beam/sdk/transforms/ParDo.java | 19 + .../sdk/transforms/reflect/DoFnInvoker.java | 26 +- .../sdk/transforms/reflect/DoFnInvokers.java | 179 +++++- .../sdk/transforms/reflect/DoFnSignature.java | 114 +++- .../sdk/transforms/reflect/DoFnSignatures.java | 366 ++++++++++++- .../splittabledofn/RestrictionTracker.java | 42 ++ .../transforms/splittabledofn/package-info.java | 22 + .../org/apache/beam/sdk/coders/KvCoderTest.java | 99 ++-- .../apache/beam/sdk/transforms/ParDoTest.java | 46 ++ .../transforms/reflect/DoFnInvokersTest.java | 261 ++++++++- .../DoFnSignaturesProcessElementTest.java | 4 +- .../DoFnSignaturesSplittableDoFnTest.java | 543 +++++++++++++++++++ 27 files changed, 3495 insertions(+), 165 deletions(-) ----------------------------------------------------------------------
