This closes #2354
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8a33591d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8a33591d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8a33591d Branch: refs/heads/master Commit: 8a33591d9bc9dfd328f3b5a3ac22be192d81531a Parents: 99056df 6671b5b Author: Amit Sela <amitsel...@gmail.com> Authored: Wed Mar 29 15:56:35 2017 +0300 Committer: Amit Sela <amitsel...@gmail.com> Committed: Wed Mar 29 15:56:35 2017 +0300 ---------------------------------------------------------------------- .../beam/runners/spark/SparkPipelineResult.java | 51 +++---- .../apache/beam/runners/spark/SparkRunner.java | 153 +++++++++---------- .../beam/runners/spark/io/SourceDStream.java | 4 +- .../SparkRunnerStreamingContextFactory.java | 43 +++--- 4 files changed, 113 insertions(+), 138 deletions(-) ----------------------------------------------------------------------
