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 <tg...@google.com> Authored: Mon Nov 28 10:06:31 2016 -0800 Committer: Thomas Groh <tg...@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(-) ----------------------------------------------------------------------
