beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [2/2] beam git commit: [BEAM-775] Remove Aggregators from the Java SDK
Date Tue, 02 May 2017 05:30:08 GMT
[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 <lcwik@google.com>
Authored: Mon May 1 22:18:20 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message