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 <bchamb...@google.com> Authored: Fri Sep 30 16:12:47 2016 -0700 Committer: bchambers <bchamb...@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(-) ----------------------------------------------------------------------