This closes #1332
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/503f26f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/503f26f4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/503f26f4 Branch: refs/heads/master Commit: 503f26f448ea9f46fcfcdd46e60cba80e4844e28 Parents: 47646d6 0331dd1 Author: Sela <ans...@paypal.com> Authored: Tue Nov 15 19:53:52 2016 +0200 Committer: Sela <ans...@paypal.com> Committed: Tue Nov 15 19:53:52 2016 +0200 ---------------------------------------------------------------------- runners/spark/pom.xml | 3 +- .../runners/spark/SparkPipelineOptions.java | 4 +- .../spark/translation/SparkRuntimeContext.java | 4 +- .../runners/spark/ProvidedSparkContextTest.java | 26 ++++----- .../metrics/sink/NamedAggregatorsTest.java | 13 +++-- .../beam/runners/spark/io/AvroPipelineTest.java | 12 ++--- .../beam/runners/spark/io/NumShardsTest.java | 10 ++-- .../io/hadoop/HadoopFileFormatPipelineTest.java | 12 ++--- .../spark/translation/SideEffectsTest.java | 11 ++-- .../streaming/EmptyStreamAssertionTest.java | 4 +- .../streaming/FlattenStreamingTest.java | 4 +- .../streaming/KafkaStreamingTest.java | 4 +- .../ResumeFromCheckpointStreamingTest.java | 4 +- .../streaming/SimpleStreamingWordCountTest.java | 6 +-- .../utils/TestOptionsForStreaming.java | 55 -------------------- .../streaming/utils/TestPipelineOptions.java | 25 +++++++++ .../utils/TestPipelineOptionsForStreaming.java | 44 ++++++++++++++++ 17 files changed, 132 insertions(+), 109 deletions(-) ----------------------------------------------------------------------
