This closes #3600
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f54072a1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f54072a1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f54072a1 Branch: refs/heads/master Commit: f54072a1b156176624db5b666ed9c308f24bc2f9 Parents: 5f1d136 1825087 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Mon Jul 24 10:03:39 2017 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Mon Jul 24 10:03:39 2017 +0200 ---------------------------------------------------------------------- .../wrappers/streaming/DoFnOperator.java | 25 ++-- .../flink/streaming/DoFnOperatorTest.java | 117 ++++++++++++++++++- 2 files changed, 134 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
