beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] beam git commit: This closes #2838
Date Tue, 02 May 2017 23:38:38 GMT
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 <dhalperi@google.com>
Authored: Tue May 2 16:38:30 2017 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message