This closes #2838
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4682238d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4682238d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4682238d Branch: refs/heads/master Commit: 4682238dc596a6d3d04b408049d7070731043cf2 Parents: 5bfd3e0 615761a Author: Dan Halperin <dhalp...@google.com> Authored: Tue May 2 16:38:30 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue May 2 16:38:30 2017 -0700 ---------------------------------------------------------------------- .../cookbook/CombinePerKeyExamples.java | 4 - .../beam/runners/core/AggregatorFactory.java | 38 ---- .../apache/beam/runners/core/DoFnRunners.java | 27 ++- .../apache/beam/runners/core/LateDataUtils.java | 6 +- .../beam/runners/core/SimpleDoFnRunner.java | 1 - .../beam/runners/core/SimpleOldDoFnRunner.java | 3 - .../core/LateDataDroppingDoFnRunnerTest.java | 27 --- .../beam/runners/core/SimpleDoFnRunnerTest.java | 9 - .../runners/core/SimpleOldDoFnRunnerTest.java | 2 +- .../runners/core/StatefulDoFnRunnerTest.java | 1 - .../runners/direct/AggregatorContainer.java | 200 ------------------- .../beam/runners/direct/EvaluationContext.java | 23 +-- .../GroupAlsoByWindowEvaluatorFactory.java | 23 +-- .../beam/runners/direct/ParDoEvaluator.java | 14 +- ...littableProcessElementsEvaluatorFactory.java | 2 - .../direct/StatefulParDoEvaluatorFactory.java | 1 - .../runners/direct/StepTransformResult.java | 8 - .../beam/runners/direct/TransformResult.java | 6 - .../beam/runners/direct/ParDoEvaluatorTest.java | 5 - .../beam/runners/spark/SparkPipelineResult.java | 5 - .../spark/aggregators/SparkAggregators.java | 110 ---------- .../SparkGroupAlsoByWindowViaWindowSet.java | 57 ++---- .../spark/translation/MultiDoFnFunction.java | 2 - ...SparkGroupAlsoByWindowViaOutputBufferFn.java | 10 - .../spark/translation/SparkRuntimeContext.java | 81 -------- .../spark/aggregators/ClearAggregatorsRule.java | 38 ---- .../metrics/sink/NamedAggregatorsTest.java | 101 ---------- .../beam/sdk/AggregatorPipelineExtractor.java | 84 -------- .../beam/sdk/AggregatorRetrievalException.java | 33 --- .../org/apache/beam/sdk/AggregatorValues.java | 51 ----- .../main/java/org/apache/beam/sdk/Pipeline.java | 10 - .../beam/sdk/annotations/Experimental.java | 3 - .../apache/beam/sdk/transforms/Aggregator.java | 14 +- .../sdk/transforms/DelegatingAggregator.java | 126 ------------ .../org/apache/beam/sdk/transforms/Latest.java | 2 - .../harness/control/ProcessBundleHandler.java | 2 - .../fn/harness/fake/FakeAggregatorFactory.java | 52 ----- 37 files changed, 52 insertions(+), 1129 deletions(-) ----------------------------------------------------------------------