You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by mx...@apache.org on 2016/04/18 16:38:16 UTC
[4/4] incubator-beam git commit: This closes #104
This closes #104
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/56e28a90
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/56e28a90
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/56e28a90
Branch: refs/heads/master
Commit: 56e28a90fe5b95c6d2c25149db1a3fe8c2205fb4
Parents: 7646384 444a0bb
Author: Maximilian Michels <mx...@apache.org>
Authored: Mon Apr 18 16:37:04 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Mon Apr 18 16:37:04 2016 +0200
----------------------------------------------------------------------
.../FlinkStreamingTransformTranslators.java | 63 +++++++++--
.../translation/wrappers/SourceInputFormat.java | 83 +++++++-------
.../streaming/io/UnboundedSourceWrapper.java | 4 +-
.../beam/runners/flink/ReadSourceITCase.java | 107 ++-----------------
.../flink/ReadSourceStreamingITCase.java | 74 +++++++++++++
5 files changed, 178 insertions(+), 153 deletions(-)
----------------------------------------------------------------------