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:53 UTC
[39/50] incubator-beam git commit: This closes #699
This closes #699
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fa0e395f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fa0e395f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fa0e395f
Branch: refs/heads/gearpump-runner
Commit: fa0e395f0ad3e874206066881a273869e75d96a3
Parents: fc87a0c adec254
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Aug 10 11:34:17 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 10 11:34:17 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/DirectRunner.java | 25 +-
.../beam/runners/flink/FlinkRunnerResult.java | 4 +-
.../runners/dataflow/DataflowPipelineJob.java | 21 +-
.../beam/runners/dataflow/DataflowRunner.java | 4 +-
.../dataflow/DataflowPipelineJobTest.java | 4 +-
.../spark/translation/EvaluationContext.java | 4 +-
.../spark/translation/SparkRuntimeContext.java | 2 +-
.../translation/MultiOutputWordCountTest.java | 2 +-
.../beam/sdk/AggregatorPipelineExtractor.java | 93 ++++++++
.../beam/sdk/AggregatorRetrievalException.java | 33 +++
.../org/apache/beam/sdk/AggregatorValues.java | 52 +++++
.../main/java/org/apache/beam/sdk/Pipeline.java | 10 +
.../org/apache/beam/sdk/PipelineResult.java | 2 -
.../runners/AggregatorPipelineExtractor.java | 93 --------
.../runners/AggregatorRetrievalException.java | 33 ---
.../beam/sdk/runners/AggregatorValues.java | 52 -----
.../beam/sdk/util/MapAggregatorValues.java | 50 ----
.../sdk/AggregatorPipelineExtractorTest.java | 229 +++++++++++++++++++
.../AggregatorPipelineExtractorTest.java | 229 -------------------
.../apache/beam/sdk/transforms/DoFnTest.java | 1 +
.../apache/beam/sdk/transforms/OldDoFnTest.java | 3 +-
21 files changed, 464 insertions(+), 482 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fa0e395f/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
----------------------------------------------------------------------