This closes #2854
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e10fbdaa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e10fbdaa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e10fbdaa Branch: refs/heads/master Commit: e10fbdaa2db480efb45074d59341ab5256a42d80 Parents: d96fd17 81b89ac Author: Stas Levin <stasle...@apache.org> Authored: Tue May 9 10:09:42 2017 +0300 Committer: Stas Levin <stasle...@apache.org> Committed: Tue May 9 10:09:42 2017 +0300 ---------------------------------------------------------------------- .../apache/beam/runners/spark/io/SourceRDD.java | 173 ++++++++++++------- .../spark/io/ReaderToIteratorAdapterTest.java | 145 ++++++++++++++++ 2 files changed, 260 insertions(+), 58 deletions(-) ----------------------------------------------------------------------
