Cherry pick #2854: [BEAM-2095] Made SourceRDD.Bounded iterator's hasNext idempotent
This closes #3120 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c79aa4c4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c79aa4c4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c79aa4c4 Branch: refs/heads/release-2.0.0 Commit: c79aa4c43fc21f7e21e84bc51eeefd4f7a38848c Parents: 64b493a 17da5e9 Author: Luke Cwik <[email protected]> Authored: Fri May 12 12:33:40 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Fri May 12 12:33:40 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/spark/io/SourceRDD.java | 173 ++++++++++++------- .../spark/io/ReaderToIteratorAdapterTest.java | 145 ++++++++++++++++ 2 files changed, 260 insertions(+), 58 deletions(-) ----------------------------------------------------------------------
