beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [2/2] incubator-beam git commit: This closes #1436
Date Sun, 27 Nov 2016 11:41:22 GMT
This closes #1436


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8cc43aa7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8cc43aa7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8cc43aa7

Branch: refs/heads/master
Commit: 8cc43aa701807009ec826e752b2f1bb95442450f
Parents: 3ad7677 cc96b13
Author: Sela <ansela@paypal.com>
Authored: Sun Nov 27 13:19:59 2016 +0200
Committer: Sela <ansela@paypal.com>
Committed: Sun Nov 27 13:19:59 2016 +0200

----------------------------------------------------------------------
 .../apache/beam/runners/spark/SparkRunner.java  | 61 +++++++++++++++++++-
 .../streaming/StreamingTransformTranslator.java |  2 +-
 .../streaming/EmptyStreamAssertionTest.java     |  2 +
 .../streaming/FlattenStreamingTest.java         |  2 +
 .../streaming/SimpleStreamingWordCountTest.java |  1 +
 .../SparkTestPipelineOptionsForStreaming.java   |  6 --
 6 files changed, 65 insertions(+), 9 deletions(-)
----------------------------------------------------------------------



Mime
View raw message