Closes #488
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3001804e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3001804e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3001804e Branch: refs/heads/master Commit: 3001804e3cb33d2d399f64e3c88308e136321782 Parents: 2b9906e 96ffc42 Author: Dan Halperin <[email protected]> Authored: Tue Jun 21 11:14:58 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue Jun 21 11:14:58 2016 -0700 ---------------------------------------------------------------------- README.md | 2 +- runners/spark/README.md | 8 +- runners/spark/pom.xml | 2 +- .../beam/runners/spark/SparkPipelineRunner.java | 255 ------------------- .../apache/beam/runners/spark/SparkRunner.java | 255 +++++++++++++++++++ .../runners/spark/SparkRunnerRegistrar.java | 8 +- .../runners/spark/TestSparkPipelineRunner.java | 77 ------ .../beam/runners/spark/TestSparkRunner.java | 77 ++++++ .../translation/SparkPipelineEvaluator.java | 6 +- .../StreamingWindowPipelineDetector.java | 6 +- .../apache/beam/runners/spark/DeDupTest.java | 4 +- .../beam/runners/spark/EmptyInputTest.java | 4 +- .../beam/runners/spark/SimpleWordCountTest.java | 8 +- .../runners/spark/SparkRunnerRegistrarTest.java | 2 +- .../apache/beam/runners/spark/TfIdfTest.java | 4 +- .../beam/runners/spark/io/AvroPipelineTest.java | 4 +- .../beam/runners/spark/io/NumShardsTest.java | 6 +- .../io/hadoop/HadoopFileFormatPipelineTest.java | 4 +- .../spark/translation/CombineGloballyTest.java | 6 +- .../spark/translation/CombinePerKeyTest.java | 4 +- .../spark/translation/DoFnOutputTest.java | 6 +- .../translation/MultiOutputWordCountTest.java | 4 +- .../spark/translation/SerializationTest.java | 6 +- .../spark/translation/SideEffectsTest.java | 4 +- .../translation/TransformTranslatorTest.java | 6 +- .../translation/WindowedWordCountTest.java | 8 +- .../streaming/FlattenStreamingTest.java | 6 +- .../streaming/KafkaStreamingTest.java | 6 +- .../streaming/SimpleStreamingWordCountTest.java | 6 +- 29 files changed, 397 insertions(+), 397 deletions(-) ----------------------------------------------------------------------
