This closes #3383: [BEAM-2447] Reintroduces DoFn.ProcessContinuation (Dataflow worker compatibility part)
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/95e6bbe5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/95e6bbe5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/95e6bbe5 Branch: refs/heads/master Commit: 95e6bbe5065a983f9c71b79b20df1fda83c9fd1b Parents: 1ea1de4 2052cc7 Author: Eugene Kirpichov <[email protected]> Authored: Mon Jun 26 17:25:14 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Mon Jun 26 17:25:14 2017 -0700 ---------------------------------------------------------------------- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../src/main/java/org/apache/beam/sdk/transforms/DoFn.java | 3 +++ .../sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java | 6 ++++++ .../org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java | 4 +++- 4 files changed, 13 insertions(+), 2 deletions(-) ----------------------------------------------------------------------
