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 <bchamb...@google.com> Authored: Thu Aug 11 10:28:04 2016 -0700 Committer: bchambers <bchamb...@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 ----------------------------------------------------------------------