beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [19/51] [abbrv] incubator-beam git commit: Closes #743
Date Sat, 06 Aug 2016 02:52:37 GMT
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 <dhalperi@google.com>
Authored: Wed Aug 3 23:01:15 2016 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message