You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/08/26 07:39:49 UTC
[2/2] incubator-beam git commit: [BEAM-294] This closes #884
[BEAM-294] This closes #884
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/20467832
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/20467832
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/20467832
Branch: refs/heads/master
Commit: 2046783235f0011e6003a2a9254b26aa5c3c27b9
Parents: b21c35d e233e5f
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Fri Aug 26 09:39:35 2016 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Fri Aug 26 09:39:35 2016 +0200
----------------------------------------------------------------------
runners/spark/pom.xml | 2 +-
.../main/java/org/apache/beam/runners/spark/SparkRunner.java | 2 +-
.../java/org/apache/beam/runners/spark/TestSparkRunner.java | 2 +-
.../beam/runners/spark/aggregators/NamedAggregators.java | 2 +-
.../org/apache/beam/runners/spark/examples/WordCount.java | 2 +-
.../runners/spark/io/hadoop/ShardNameTemplateHelper.java | 6 +++---
.../apache/beam/runners/spark/translation/DoFnFunction.java | 2 +-
.../runners/spark/translation/SparkPipelineTranslator.java | 2 +-
.../beam/runners/spark/translation/SparkRuntimeContext.java | 2 +-
.../beam/runners/spark/translation/TransformTranslator.java | 4 ++--
.../translation/streaming/StreamingTransformTranslator.java | 8 ++++----
.../org/apache/beam/runners/spark/util/BroadcastHelper.java | 4 ++--
.../runners/spark/translation/TransformTranslatorTest.java | 2 +-
.../spark/translation/streaming/KafkaStreamingTest.java | 2 +-
14 files changed, 21 insertions(+), 21 deletions(-)
----------------------------------------------------------------------