You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/06/21 18:15:08 UTC
[2/2] incubator-beam git commit: Closes #488
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 <dh...@google.com>
Authored: Tue Jun 21 11:14:58 2016 -0700
Committer: Dan Halperin <dh...@google.com>
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(-)
----------------------------------------------------------------------