You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/08/11 18:41:19 UTC

[3/3] incubator-beam git commit: This closes #815

This closes #815


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a0769ad2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a0769ad2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a0769ad2

Branch: refs/heads/master
Commit: a0769ad2a348c1296086b9dc8994e32ba5a06760
Parents: 3a858ee d20a7ad
Author: bchambers <bc...@google.com>
Authored: Thu Aug 11 10:28:04 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Thu Aug 11 11:06:56 2016 -0700

----------------------------------------------------------------------
 .../org/apache/beam/sdk/util/DoFnRunners.java   |   78 --
 .../beam/runners/dataflow/DataflowRunner.java   |    4 +-
 .../org/apache/beam/sdk/transforms/Combine.java |   13 -
 .../org/apache/beam/sdk/transforms/Max.java     |   27 +-
 .../org/apache/beam/sdk/transforms/Min.java     |   28 +-
 .../org/apache/beam/sdk/transforms/Sum.java     |   27 +-
 .../apache/beam/sdk/util/CounterAggregator.java |  128 --
 .../apache/beam/sdk/util/common/Counter.java    | 1287 ------------------
 .../beam/sdk/util/common/CounterName.java       |  153 ---
 .../beam/sdk/util/common/CounterProvider.java   |   27 -
 .../apache/beam/sdk/util/common/CounterSet.java |  179 ---
 .../util/common/ElementByteSizeObserver.java    |   24 +-
 .../beam/sdk/util/CounterAggregatorTest.java    |  256 ----
 .../beam/sdk/util/common/CounterSetTest.java    |  227 ---
 .../beam/sdk/util/common/CounterTest.java       |  736 ----------
 15 files changed, 15 insertions(+), 3179 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a0769ad2/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
----------------------------------------------------------------------