This closes #1436
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8cc43aa7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8cc43aa7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8cc43aa7 Branch: refs/heads/master Commit: 8cc43aa701807009ec826e752b2f1bb95442450f Parents: 3ad7677 cc96b13 Author: Sela <ans...@paypal.com> Authored: Sun Nov 27 13:19:59 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Sun Nov 27 13:19:59 2016 +0200 ---------------------------------------------------------------------- .../apache/beam/runners/spark/SparkRunner.java | 61 +++++++++++++++++++- .../streaming/StreamingTransformTranslator.java | 2 +- .../streaming/EmptyStreamAssertionTest.java | 2 + .../streaming/FlattenStreamingTest.java | 2 + .../streaming/SimpleStreamingWordCountTest.java | 1 + .../SparkTestPipelineOptionsForStreaming.java | 6 -- 6 files changed, 65 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
