You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/04 19:53:58 UTC
[33/50] [abbrv] beam git commit: This closes #2838
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/gearpump-runner
Commit: 4682238dc596a6d3d04b408049d7070731043cf2
Parents: 5bfd3e0 615761a
Author: Dan Halperin <dh...@google.com>
Authored: Tue May 2 16:38:30 2017 -0700
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------