beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] incubator-beam git commit: Closes #488
Date Tue, 21 Jun 2016 18:15:08 GMT
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 <dhalperi@google.com>
Authored: Tue Jun 21 11:14:58 2016 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message