You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/09/30 23:21:28 UTC
[2/2] incubator-beam git commit: Closes #1029
Closes #1029
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bc80ee34
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bc80ee34
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bc80ee34
Branch: refs/heads/master
Commit: bc80ee342749768bbfc2a9fda80a4b15680e5898
Parents: b237e2f 3e7c396
Author: bchambers <bc...@google.com>
Authored: Fri Sep 30 16:12:47 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Fri Sep 30 16:12:47 2016 -0700
----------------------------------------------------------------------
.../beam/runners/dataflow/DataflowRunner.java | 8 ++
.../DataflowUnboundedReadFromBoundedSource.java | 16 +++-
...aflowUnboundedReadFromBoundedSourceTest.java | 82 ++++++++++++++++++++
.../sdk/io/BoundedReadFromUnboundedSource.java | 6 ++
.../java/org/apache/beam/sdk/io/ReadTest.java | 56 ++++++++++++-
.../display/DisplayDataEvaluator.java | 7 +-
6 files changed, 168 insertions(+), 7 deletions(-)
----------------------------------------------------------------------