This closes #1495
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ca6ab6c6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ca6ab6c6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ca6ab6c6 Branch: refs/heads/master Commit: ca6ab6c68d807765ab8e80273dd9d6f99aeaaf4a Parents: 077d911 ec1eff3 Author: Thomas Groh <[email protected]> Authored: Tue Dec 6 10:46:40 2016 -0800 Committer: Thomas Groh <[email protected]> Committed: Tue Dec 6 10:46:40 2016 -0800 ---------------------------------------------------------------------- .../direct/BoundedReadEvaluatorFactoryTest.java | 18 +- .../runners/direct/DirectGraphVisitorTest.java | 69 ++++-- .../beam/runners/direct/DirectGraphs.java | 35 +++ .../runners/direct/EvaluationContextTest.java | 82 ++++--- .../direct/FlattenEvaluatorFactoryTest.java | 15 +- .../direct/GroupByKeyEvaluatorFactoryTest.java | 2 +- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 3 +- .../ImmutabilityEnforcementFactoryTest.java | 2 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 3 +- .../StatefulParDoEvaluatorFactoryTest.java | 4 +- .../runners/direct/StepTransformResultTest.java | 2 +- .../direct/TestStreamEvaluatorFactoryTest.java | 14 +- .../runners/direct/TransformExecutorTest.java | 9 +- .../UnboundedReadEvaluatorFactoryTest.java | 24 +- .../direct/ViewEvaluatorFactoryTest.java | 4 +- .../direct/WatermarkCallbackExecutorTest.java | 6 +- .../runners/direct/WatermarkManagerTest.java | 237 ++++++++----------- 17 files changed, 292 insertions(+), 237 deletions(-) ----------------------------------------------------------------------
