You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/04/15 00:09:06 UTC
[2/2] incubator-beam git commit: [BEAM-22] This closes #167
[BEAM-22] This closes #167
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6511ba28
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6511ba28
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6511ba28
Branch: refs/heads/master
Commit: 6511ba28e4edbe9945df998df362787e8dbeb401
Parents: 96765f1 11ba2b9
Author: Luke Cwik <lc...@google.com>
Authored: Thu Apr 14 15:08:50 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Apr 14 15:08:50 2016 -0700
----------------------------------------------------------------------
.../beam/runners/spark/SparkPipelineRunner.java | 6 ++-
.../SparkPipelineOptionsFactory.java | 31 ---------------
.../SparkStreamingPipelineOptionsFactory.java | 31 ---------------
.../apache/beam/runners/spark/DeDupTest.java | 16 ++++----
.../beam/runners/spark/EmptyInputTest.java | 15 +++++---
.../beam/runners/spark/SimpleWordCountTest.java | 18 +++++----
.../apache/beam/runners/spark/TfIdfTest.java | 11 ++++--
.../runners/spark/coders/WritableCoderTest.java | 1 +
.../beam/runners/spark/io/AvroPipelineTest.java | 22 ++++++-----
.../beam/runners/spark/io/NumShardsTest.java | 26 +++++++------
.../io/hadoop/HadoopFileFormatPipelineTest.java | 7 ++--
.../spark/io/hadoop/ShardNameBuilderTest.java | 1 +
.../spark/translation/CombineGloballyTest.java | 14 ++++---
.../spark/translation/CombinePerKeyTest.java | 12 +++---
.../spark/translation/DoFnOutputTest.java | 8 ++--
.../translation/MultiOutputWordCountTest.java | 10 +++--
.../spark/translation/SerializationTest.java | 27 +++++++------
.../spark/translation/SideEffectsTest.java | 10 +++--
.../translation/SparkPipelineOptionsTest.java | 40 ++++++++++++++++++++
.../TestSparkPipelineOptionsFactory.java | 38 -------------------
.../translation/TransformTranslatorTest.java | 20 +++++-----
.../translation/WindowedWordCountTest.java | 10 +++--
.../streaming/FlattenStreamingTest.java | 13 ++++---
.../streaming/KafkaStreamingTest.java | 24 +++++++-----
.../streaming/SimpleStreamingWordCountTest.java | 20 ++++++----
.../streaming/utils/EmbeddedKafkaCluster.java | 11 +++---
.../streaming/utils/PAssertStreaming.java | 1 +
27 files changed, 217 insertions(+), 226 deletions(-)
----------------------------------------------------------------------