You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/06/02 00:57:04 UTC
[3/3] incubator-beam git commit: Closes #411
Closes #411
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1da797d8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1da797d8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1da797d8
Branch: refs/heads/master
Commit: 1da797d8f5dfae73cd7574c2d388e9ba3317a839
Parents: b9a8cbe e3cc4fa
Author: Dan Halperin <dh...@google.com>
Authored: Wed Jun 1 17:56:38 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Wed Jun 1 17:56:38 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/BundleFactory.java | 4 +-
.../direct/ExecutorServiceParallelExecutor.java | 8 +-
.../ImmutabilityCheckingBundleFactory.java | 4 +-
.../direct/InMemoryWatermarkManager.java | 70 ++++++++-------
.../runners/direct/InProcessBundleFactory.java | 25 +++---
.../direct/InProcessEvaluationContext.java | 10 +--
.../direct/InProcessExecutionContext.java | 4 +-
...InProcessGroupByKeyOnlyEvaluatorFactory.java | 6 +-
.../runners/direct/InProcessPipelineRunner.java | 7 +-
.../apache/beam/runners/direct/StepAndKey.java | 8 +-
.../beam/runners/direct/StructuralKey.java | 77 ++++++++++++++++
.../direct/GroupByKeyEvaluatorFactoryTest.java | 27 ++++--
.../ImmutabilityCheckingBundleFactoryTest.java | 13 ++-
.../direct/InMemoryWatermarkManagerTest.java | 95 +++++++++++---------
.../direct/InProcessBundleFactoryTest.java | 54 ++++++-----
.../direct/InProcessEvaluationContextTest.java | 52 ++++++-----
...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 33 ++++---
.../direct/InProcessPipelineRunnerTest.java | 60 +++++++++++++
.../direct/InProcessTimerInternalsTest.java | 3 +-
.../direct/ParDoInProcessEvaluatorTest.java | 2 +-
.../direct/ParDoMultiEvaluatorFactoryTest.java | 29 +++---
.../direct/ParDoSingleEvaluatorFactoryTest.java | 35 +++++---
.../beam/runners/direct/StructuralKeyTest.java | 81 +++++++++++++++++
23 files changed, 500 insertions(+), 207 deletions(-)
----------------------------------------------------------------------