This closes #2288
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9ac1ffce Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9ac1ffce Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9ac1ffce Branch: refs/heads/master Commit: 9ac1ffceadb30956655e27d253fd84fe355d5f54 Parents: 5e1be9f 623a569 Author: Aviem Zur <[email protected]> Authored: Thu Mar 23 16:48:04 2017 +0200 Committer: Aviem Zur <[email protected]> Committed: Thu Mar 23 16:48:04 2017 +0200 ---------------------------------------------------------------------- .../spark/SparkNativePipelineVisitor.java | 1 - .../beam/runners/spark/io/SourceDStream.java | 52 +++++++++++++++----- .../apache/beam/runners/spark/io/SourceRDD.java | 19 +++++-- .../runners/spark/io/SparkUnboundedSource.java | 15 +++--- 4 files changed, 63 insertions(+), 24 deletions(-) ----------------------------------------------------------------------
