You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/08/06 02:52:37 UTC
[19/51] [abbrv] incubator-beam git commit: Closes #743
Closes #743
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3144363c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3144363c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3144363c
Branch: refs/heads/python-sdk
Commit: 3144363c067e8bd5d1b83aca2f4057b6bc33ed04
Parents: c314e67 ac0875d
Author: Dan Halperin <dh...@google.com>
Authored: Wed Aug 3 23:01:15 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Wed Aug 3 23:01:15 2016 -0700
----------------------------------------------------------------------
.../runners/spark/SparkPipelineOptions.java | 6 ++++
.../apache/beam/runners/spark/SparkRunner.java | 14 +++------
.../runners/spark/SparkRunnerRegistrar.java | 6 ++--
.../spark/SparkStreamingPipelineOptions.java | 32 --------------------
.../beam/runners/spark/TestSparkRunner.java | 2 --
.../apache/beam/runners/spark/DeDupTest.java | 2 +-
.../beam/runners/spark/EmptyInputTest.java | 2 +-
.../beam/runners/spark/SimpleWordCountTest.java | 4 +--
.../runners/spark/SparkRunnerRegistrarTest.java | 2 +-
.../apache/beam/runners/spark/TfIdfTest.java | 2 +-
.../beam/runners/spark/io/AvroPipelineTest.java | 2 +-
.../beam/runners/spark/io/NumShardsTest.java | 2 +-
.../io/hadoop/HadoopFileFormatPipelineTest.java | 2 +-
.../spark/translation/CombineGloballyTest.java | 2 +-
.../spark/translation/CombinePerKeyTest.java | 2 +-
.../spark/translation/DoFnOutputTest.java | 6 ++--
.../translation/MultiOutputWordCountTest.java | 2 +-
.../spark/translation/SerializationTest.java | 2 +-
.../spark/translation/SideEffectsTest.java | 8 ++---
.../streaming/FlattenStreamingTest.java | 8 ++---
.../streaming/KafkaStreamingTest.java | 13 ++++----
.../streaming/SimpleStreamingWordCountTest.java | 8 ++---
.../streaming/utils/EmbeddedKafkaCluster.java | 4 ++-
23 files changed, 49 insertions(+), 84 deletions(-)
----------------------------------------------------------------------