beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] incubator-beam git commit: This Closes #274
Date Tue, 10 May 2016 20:27:03 GMT
This Closes #274


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4020e364
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4020e364
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4020e364

Branch: refs/heads/master
Commit: 4020e364598befbd68458f1c6eada6d90a986358
Parents: 874ddef 336e90f
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Tue May 10 22:20:47 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Tue May 10 22:20:47 2016 +0200

----------------------------------------------------------------------
 .../flink/DefaultParallelismFactory.java        |  39 +++
 .../runners/flink/FlinkPipelineOptions.java     |   2 +-
 .../FlinkStreamingTransformTranslators.java     |  18 +-
 .../streaming/io/UnboundedSourceWrapper.java    | 337 ++++++++++++++++---
 .../flink/streaming/TestCountingSource.java     | 256 ++++++++++++++
 .../flink/streaming/UnboundedSourceITCase.java  | 208 ------------
 .../streaming/UnboundedSourceWrapperTest.java   | 324 ++++++++++++++++++
 7 files changed, 916 insertions(+), 268 deletions(-)
----------------------------------------------------------------------



Mime
View raw message