You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/10/06 22:31:20 UTC
[4/4] incubator-beam git commit: [BEAM-310] Add
RootTransformEvaluatorFactory
[BEAM-310] Add RootTransformEvaluatorFactory
This closes #1051
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ecbc6411
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ecbc6411
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ecbc6411
Branch: refs/heads/master
Commit: ecbc64117e3bb4e1be35a7539463e62e1a3ba303
Parents: 0ddba6d 41fb16f
Author: Luke Cwik <lc...@google.com>
Authored: Thu Oct 6 15:15:12 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Oct 6 15:15:12 2016 -0700
----------------------------------------------------------------------
.../examples/complete/game/LeaderBoardTest.java | 5 +-
.../direct/BoundedReadEvaluatorFactory.java | 123 ++++-----
.../beam/runners/direct/DirectRunner.java | 2 +
.../runners/direct/DirectTimerInternals.java | 2 +-
.../beam/runners/direct/EmptyInputProvider.java | 49 ++++
.../beam/runners/direct/EvaluationContext.java | 5 +
.../direct/ExecutorServiceParallelExecutor.java | 77 ++++--
.../runners/direct/FlattenEvaluatorFactory.java | 17 +-
.../beam/runners/direct/KeyedResourcePool.java | 47 ----
.../runners/direct/LockedKeyedResourcePool.java | 95 -------
.../beam/runners/direct/RootInputProvider.java | 41 +++
.../runners/direct/RootProviderRegistry.java | 65 +++++
.../direct/TestStreamEvaluatorFactory.java | 137 +++++-----
.../direct/TransformEvaluatorFactory.java | 2 +-
.../direct/TransformEvaluatorRegistry.java | 9 +-
.../direct/UnboundedReadEvaluatorFactory.java | 273 ++++++++++---------
.../beam/runners/direct/WatermarkManager.java | 11 +
.../direct/BoundedReadEvaluatorFactoryTest.java | 140 +++++-----
.../direct/FlattenEvaluatorFactoryTest.java | 15 +-
.../direct/LockedKeyedResourcePoolTest.java | 163 -----------
.../direct/TestStreamEvaluatorFactoryTest.java | 197 ++++++-------
.../UnboundedReadEvaluatorFactoryTest.java | 204 +++++++-------
22 files changed, 786 insertions(+), 893 deletions(-)
----------------------------------------------------------------------