Repository: incubator-beam Updated Branches: refs/heads/master 7fb21f223 -> 61d8cf2c4
Closes #340 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/61d8cf2c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/61d8cf2c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/61d8cf2c Branch: refs/heads/master Commit: 61d8cf2c48c2c5bd6cbdd8c2755cac5be4b6777c Parents: 7fb21f2 269da95 Author: Dan Halperin <[email protected]> Authored: Wed Jun 8 12:45:31 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed Jun 8 12:45:31 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/UnboundedSource.java | 47 +++++++++++++++----- 1 file changed, 35 insertions(+), 12 deletions(-) ----------------------------------------------------------------------
