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 <bchamb...@google.com> Authored: Thu Jul 28 17:22:03 2016 -0700 Committer: bchambers <bchamb...@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(-) ----------------------------------------------------------------------