This closes #2127
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/79b1395c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/79b1395c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/79b1395c Branch: refs/heads/master Commit: 79b1395c25e23bf7ff3946cf9ffd2c01b048d722 Parents: d66029c 6e9f7ad Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Wed Mar 1 18:01:06 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Wed Mar 1 18:01:06 2017 +0100 ---------------------------------------------------------------------- .../apache/beam/runners/core/DoFnRunners.java | 39 +++ .../beam/runners/core/StatefulDoFnRunner.java | 233 +++++++++++++++++ .../runners/core/StatefulDoFnRunnerTest.java | 255 +++++++++++++++++++ .../wrappers/streaming/DoFnOperator.java | 4 + 4 files changed, 531 insertions(+) ----------------------------------------------------------------------
