This closes #3360: [BEAM-2447] Reintroduces DoFn.ProcessContinuation
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/66b4a1be Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/66b4a1be Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/66b4a1be Branch: refs/heads/master Commit: 66b4a1be09b58a761cf49cc18a04eaaff555e376 Parents: 91c7d3d 1bff4a7 Author: Eugene Kirpichov <[email protected]> Authored: Wed Jul 12 16:16:05 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Wed Jul 12 16:16:05 2017 -0700 ---------------------------------------------------------------------- .../core/construction/SplittableParDoTest.java | 10 +- ...eBoundedSplittableProcessElementInvoker.java | 35 ++++++- .../core/SplittableParDoViaKeyedWorkItems.java | 9 +- .../core/SplittableProcessElementInvoker.java | 25 ++++- ...ndedSplittableProcessElementInvokerTest.java | 45 +++++++-- .../core/SplittableParDoProcessFnTest.java | 99 ++++++++++++++++-- .../org/apache/beam/sdk/transforms/DoFn.java | 51 +++++++++- .../reflect/ByteBuddyDoFnInvokerFactory.java | 19 +++- .../sdk/transforms/reflect/DoFnInvoker.java | 4 +- .../sdk/transforms/reflect/DoFnSignature.java | 10 +- .../sdk/transforms/reflect/DoFnSignatures.java | 22 +++- .../splittabledofn/OffsetRangeTracker.java | 10 ++ .../splittabledofn/RestrictionTracker.java | 11 +- .../beam/sdk/transforms/SplittableDoFnTest.java | 100 ++++++++----------- .../transforms/reflect/DoFnInvokersTest.java | 93 +++++++++++++---- .../DoFnSignaturesProcessElementTest.java | 2 +- .../DoFnSignaturesSplittableDoFnTest.java | 83 +++++++++++++-- 17 files changed, 487 insertions(+), 141 deletions(-) ----------------------------------------------------------------------
