You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/07/29 01:01:58 UTC
[2/2] incubator-beam git commit: Implement aggregators directly in
the direct runner
Implement aggregators directly in the direct runner
This closes #735
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1df6f5f9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1df6f5f9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1df6f5f9
Branch: refs/heads/master
Commit: 1df6f5f976108aa584abbb8a9412578e1f6a621b
Parents: 9c44751 15eb67b
Author: bchambers <bc...@google.com>
Authored: Thu Jul 28 17:22:03 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Thu Jul 28 17:22:03 2016 -0700
----------------------------------------------------------------------
.../apache/beam/sdk/util/DoFnRunnerBase.java | 28 +--
.../org/apache/beam/sdk/util/DoFnRunners.java | 92 +++++++++-
.../apache/beam/sdk/util/SimpleDoFnRunner.java | 7 +-
.../runners/direct/AggregatorContainer.java | 183 +++++++++++++++++++
.../beam/runners/direct/DirectRunner.java | 14 +-
.../beam/runners/direct/EvaluationContext.java | 32 ++--
.../beam/runners/direct/ParDoEvaluator.java | 16 +-
.../runners/direct/StepTransformResult.java | 15 +-
.../beam/runners/direct/TransformResult.java | 9 +-
.../runners/direct/AggregatorContainerTest.java | 134 ++++++++++++++
.../beam/runners/direct/DirectRunnerTest.java | 4 -
.../runners/direct/EvaluationContextTest.java | 35 ++--
.../beam/runners/direct/ParDoEvaluatorTest.java | 11 +-
.../direct/ParDoMultiEvaluatorFactoryTest.java | 31 ++--
.../direct/ParDoSingleEvaluatorFactoryTest.java | 31 ++--
.../apache/beam/sdk/transforms/Aggregator.java | 24 ++-
.../apache/beam/sdk/transforms/DoFnTester.java | 7 +-
.../apache/beam/sdk/util/CounterAggregator.java | 35 +++-
.../apache/beam/sdk/transforms/DoFnTest.java | 35 ++++
19 files changed, 592 insertions(+), 151 deletions(-)
----------------------------------------------------------------------