beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [4/4] incubator-beam git commit: This closes #104
Date Mon, 18 Apr 2016 14:38:16 GMT
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 <mxm@apache.org>
Authored: Mon Apr 18 16:37:04 2016 +0200
Committer: Maximilian Michels <mxm@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(-)
----------------------------------------------------------------------



Mime
View raw message