Closes #550
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/12b6ff8d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/12b6ff8d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/12b6ff8d Branch: refs/heads/master Commit: 12b6ff8d79b03b195d184acf5d718a82254e880e Parents: e01efbd 4f2ac39 Author: Dan Halperin <[email protected]> Authored: Wed Jun 29 22:45:45 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed Jun 29 22:45:45 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 34 +- .../DataflowUnboundedReadFromBoundedSource.java | 547 +++++++++++++++++++ .../runners/dataflow/DataflowRunnerTest.java | 30 - 3 files changed, 577 insertions(+), 34 deletions(-) ----------------------------------------------------------------------
