This closes #1878
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/99f93eb0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/99f93eb0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/99f93eb0 Branch: refs/heads/master Commit: 99f93eb078819882f622d953ff05ca419516c90f Parents: cef3109 b56f460 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Feb 3 13:54:18 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Feb 3 13:54:18 2017 +0100 ---------------------------------------------------------------------- runners/flink/runner/pom.xml | 1 - .../FlinkStreamingTransformTranslators.java | 137 ++++++++++++++----- .../wrappers/streaming/DoFnOperator.java | 15 +- .../streaming/KvToByteBufferKeySelector.java | 56 ++++++++ .../wrappers/streaming/WindowDoFnOperator.java | 13 +- .../beam/runners/flink/PipelineOptionsTest.java | 4 +- .../flink/streaming/DoFnOperatorTest.java | 9 +- 7 files changed, 182 insertions(+), 53 deletions(-) ----------------------------------------------------------------------
