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 <[email protected]> Authored: Wed Aug 10 11:34:17 2016 -0700 Committer: Kenneth Knowles <[email protected]> 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 ----------------------------------------------------------------------
