You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by al...@apache.org on 2016/05/10 20:27:03 UTC

[2/2] incubator-beam git commit: This Closes #274

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 <al...@gmail.com>
Authored: Tue May 10 22:20:47 2016 +0200
Committer: Aljoscha Krettek <al...@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(-)
----------------------------------------------------------------------