This closes #2229
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e362e6b4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e362e6b4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e362e6b4 Branch: refs/heads/master Commit: e362e6b49c4ade94d51f6f96e117734afdc67d14 Parents: 9ad01fb f762147 Author: Aljoscha Krettek <[email protected]> Authored: Tue Mar 14 11:55:09 2017 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Mar 14 11:55:09 2017 +0100 ---------------------------------------------------------------------- .../beam/runners/core/StatefulDoFnRunner.java | 96 ++++++++++++++++ .../runners/core/StatefulDoFnRunnerTest.java | 113 ++++--------------- .../wrappers/streaming/DoFnOperator.java | 95 +--------------- .../flink/streaming/DoFnOperatorTest.java | 9 +- 4 files changed, 126 insertions(+), 187 deletions(-) ----------------------------------------------------------------------
