beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] beam git commit: This closes #1878
Date Fri, 03 Feb 2017 12:55:14 GMT
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.krettek@gmail.com>
Authored: Fri Feb 3 13:54:18 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@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(-)
----------------------------------------------------------------------



Mime
View raw message