Repository: incubator-beam
Updated Branches:
refs/heads/master 9fbd2d24e -> 5e9a80cf6
This closes #1424
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5e9a80cf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5e9a80cf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5e9a80cf
Branch: refs/heads/master
Commit: 5e9a80cf61c4666edb5febd9a0fface2d2c26261
Parents: 9fbd2d2 7502add
Author: Thomas Groh <tgroh@google.com>
Authored: Mon Nov 28 10:06:31 2016 -0800
Committer: Thomas Groh <tgroh@google.com>
Committed: Mon Nov 28 10:06:31 2016 -0800
----------------------------------------------------------------------
.../direct/AbstractModelEnforcement.java | 2 +-
.../direct/BoundedReadEvaluatorFactory.java | 2 +-
.../beam/runners/direct/CommittedResult.java | 2 +-
.../beam/runners/direct/CompletionCallback.java | 2 +-
...ecycleManagerRemovingTransformEvaluator.java | 2 +-
.../runners/direct/EmptyTransformEvaluator.java | 4 +-
.../beam/runners/direct/EvaluationContext.java | 2 +-
.../direct/ExecutorServiceParallelExecutor.java | 2 +-
.../runners/direct/FlattenEvaluatorFactory.java | 10 ++---
.../GroupAlsoByWindowEvaluatorFactory.java | 5 ++-
.../direct/GroupByKeyOnlyEvaluatorFactory.java | 2 +-
.../direct/ImmutabilityEnforcementFactory.java | 2 +-
.../beam/runners/direct/ModelEnforcement.java | 2 +-
.../beam/runners/direct/ParDoEvaluator.java | 2 +-
.../direct/PassthroughTransformEvaluator.java | 4 +-
.../runners/direct/StepTransformResult.java | 38 +++++++++--------
.../direct/TestStreamEvaluatorFactory.java | 2 +-
.../beam/runners/direct/TransformEvaluator.java | 2 +-
.../beam/runners/direct/TransformExecutor.java | 4 +-
.../beam/runners/direct/TransformResult.java | 16 +++++--
.../direct/UnboundedReadEvaluatorFactory.java | 3 +-
.../runners/direct/ViewEvaluatorFactory.java | 2 +-
.../runners/direct/WindowEvaluatorFactory.java | 6 ++-
.../direct/BoundedReadEvaluatorFactoryTest.java | 10 ++---
...leManagerRemovingTransformEvaluatorTest.java | 4 +-
.../runners/direct/EvaluationContextTest.java | 20 ++++-----
.../direct/FlattenEvaluatorFactoryTest.java | 6 +--
.../ImmutabilityEnforcementFactoryTest.java | 6 +--
.../beam/runners/direct/ParDoEvaluatorTest.java | 2 +-
.../runners/direct/StepTransformResultTest.java | 25 ++++++-----
.../direct/TestStreamEvaluatorFactoryTest.java | 10 ++---
.../runners/direct/TransformExecutorTest.java | 45 ++++++++++----------
.../UnboundedReadEvaluatorFactoryTest.java | 20 ++++++---
.../direct/WindowEvaluatorFactoryTest.java | 12 +++---
34 files changed, 152 insertions(+), 126 deletions(-)
----------------------------------------------------------------------
|