[BEAM-775] Remove Aggregators from the Java SDK This closes #2718
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/87cf88ad Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/87cf88ad Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/87cf88ad Branch: refs/heads/master Commit: 87cf88ade7459722f9daf902cd76ea56a180a041 Parents: 19ae45b 4253a60 Author: Luke Cwik <lc...@google.com> Authored: Mon May 1 22:18:20 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Mon May 1 22:18:20 2017 -0700 ---------------------------------------------------------------------- .../operators/ApexGroupByKeyOperator.java | 1 - .../apache/beam/runners/core/DoFnAdapters.java | 18 -- .../apache/beam/runners/core/DoFnRunners.java | 6 +- .../GroupAlsoByWindowViaOutputBufferDoFn.java | 1 - .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 1 - .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 12 - .../core/LateDataDroppingDoFnRunner.java | 20 +- ...eBoundedSplittableProcessElementInvoker.java | 8 - .../beam/runners/core/ReduceFnRunner.java | 15 +- .../beam/runners/core/SimpleDoFnRunner.java | 24 -- .../beam/runners/core/SplittableParDo.java | 8 - .../core/LateDataDroppingDoFnRunnerTest.java | 20 +- .../beam/runners/core/ReduceFnRunnerTest.java | 69 ++++-- .../beam/runners/core/ReduceFnTester.java | 38 ---- .../beam/runners/direct/DirectRunner.java | 10 +- .../GroupAlsoByWindowEvaluatorFactory.java | 1 - .../wrappers/streaming/DoFnOperator.java | 3 +- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../SparkGroupAlsoByWindowViaWindowSet.java | 1 - ...SparkGroupAlsoByWindowViaOutputBufferFn.java | 1 - .../beam/sdk/AggregatorPipelineExtractor.java | 10 +- .../apache/beam/sdk/transforms/Aggregator.java | 24 -- .../sdk/transforms/AggregatorRetriever.java | 45 ---- .../org/apache/beam/sdk/transforms/DoFn.java | 120 +--------- .../apache/beam/sdk/transforms/DoFnTester.java | 64 ------ .../org/apache/beam/sdk/transforms/Latest.java | 3 +- .../sdk/AggregatorPipelineExtractorTest.java | 226 ------------------- .../apache/beam/sdk/transforms/DoFnTest.java | 162 ------------- .../beam/sdk/transforms/DoFnTesterTest.java | 47 +--- .../beam/sdk/transforms/LatestFnTest.java | 40 ---- 30 files changed, 106 insertions(+), 894 deletions(-) ----------------------------------------------------------------------
