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/11/23 06:52:17 UTC
[21/50] incubator-beam git commit: This closes #1393
This closes #1393
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/875631f0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/875631f0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/875631f0
Branch: refs/heads/gearpump-runner
Commit: 875631f07b1e4556afec28dc850bd7fe2d07444b
Parents: d93e9a8 dafd5be
Author: Sela <an...@paypal.com>
Authored: Sun Nov 20 19:26:52 2016 +0200
Committer: Sela <an...@paypal.com>
Committed: Sun Nov 20 19:26:52 2016 +0200
----------------------------------------------------------------------
.../runners/spark/SparkPipelineOptions.java | 6 --
.../apache/beam/runners/spark/SparkRunner.java | 5 +-
.../spark/translation/EvaluationContext.java | 59 +++++++++++++-------
.../SparkRunnerStreamingContextFactory.java | 3 +-
.../streaming/EmptyStreamAssertionTest.java | 3 +-
.../streaming/FlattenStreamingTest.java | 4 +-
.../streaming/KafkaStreamingTest.java | 11 ++--
.../ResumeFromCheckpointStreamingTest.java | 3 +-
.../streaming/SimpleStreamingWordCountTest.java | 4 +-
.../streaming/utils/PAssertStreaming.java | 8 ++-
.../SparkTestPipelineOptionsForStreaming.java | 1 -
11 files changed, 60 insertions(+), 47 deletions(-)
----------------------------------------------------------------------