beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [4/4] incubator-beam git commit: This closes #699
Date Wed, 10 Aug 2016 18:34:43 GMT
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/master
Commit: fa0e395f0ad3e874206066881a273869e75d96a3
Parents: fc87a0c adec254
Author: Kenneth Knowles <klk@google.com>
Authored: Wed Aug 10 11:34:17 2016 -0700
Committer: Kenneth Knowles <klk@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
----------------------------------------------------------------------


Mime
View raw message