This closes #1895: ProcessFn: support setup/teardown
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4e10976 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4e10976 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f4e10976 Branch: refs/heads/master Commit: f4e10976789aa5fe4b350be21df29544fa626251 Parents: 224e447 b6877ce Author: Kenneth Knowles <k...@google.com> Authored: Mon Feb 6 14:50:36 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Feb 6 14:50:36 2017 -0800 ---------------------------------------------------------------------- .../beam/runners/core/SplittableParDo.java | 16 ++++- .../beam/runners/core/SplittableParDoTest.java | 73 +++++++++++++++++++- .../runners/direct/ParDoEvaluatorFactory.java | 5 +- ...littableProcessElementsEvaluatorFactory.java | 11 ++- 4 files changed, 96 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/f4e10976/runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDo.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/f4e10976/runners/core-java/src/test/java/org/apache/beam/runners/core/SplittableParDoTest.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/f4e10976/runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java ----------------------------------------------------------------------
