You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/12 19:33:54 UTC

[2/2] beam git commit: Cherry pick #2854: [BEAM-2095] Made SourceRDD.Bounded iterator's hasNext idempotent

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 <lc...@google.com>
Authored: Fri May 12 12:33:40 2017 -0700
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------