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/08/25 18:55:51 UTC
[37/50] incubator-beam git commit: [BEAM-542] Spark batch interval
should be a configuration instead of an interpretation of the Pipeline's
windows
[BEAM-542] Spark batch interval should be a configuration instead of an interpretation of the Pipeline's windows
This closes #808
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fc87a0ca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fc87a0ca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fc87a0ca
Branch: refs/heads/gearpump-runner
Commit: fc87a0ca73598bf2e9021697425bcff52d962f10
Parents: 0ab9495 08dca30
Author: Sela <an...@paypal.com>
Authored: Wed Aug 10 20:50:15 2016 +0300
Committer: Sela <an...@paypal.com>
Committed: Wed Aug 10 20:50:15 2016 +0300
----------------------------------------------------------------------
runners/spark/README.md | 3 +-
.../runners/spark/SparkPipelineOptions.java | 5 +
.../apache/beam/runners/spark/SparkRunner.java | 19 +---
.../streaming/StreamingTransformTranslator.java | 10 +-
.../StreamingWindowPipelineDetector.java | 102 -------------------
.../streaming/FlattenStreamingTest.java | 1 +
.../streaming/KafkaStreamingTest.java | 2 +
.../streaming/SimpleStreamingWordCountTest.java | 2 +
8 files changed, 18 insertions(+), 126 deletions(-)
----------------------------------------------------------------------