This closes #1487
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1abbb900 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1abbb900 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1abbb900 Branch: refs/heads/master Commit: 1abbb9007e83fc64f1bb61ff4593f37c6c386545 Parents: 8cb2689 662416a Author: Thomas Groh <tg...@google.com> Authored: Fri Dec 2 14:02:25 2016 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Fri Dec 2 14:02:25 2016 -0800 ---------------------------------------------------------------------- .../direct/ConsumerTrackingPipelineVisitor.java | 173 ----------- .../apache/beam/runners/direct/DirectGraph.java | 89 ++++++ .../beam/runners/direct/DirectGraphVisitor.java | 145 ++++++++++ .../beam/runners/direct/DirectRunner.java | 35 +-- .../beam/runners/direct/EvaluationContext.java | 76 ++--- .../direct/ExecutorServiceParallelExecutor.java | 15 +- .../ImmutabilityCheckingBundleFactory.java | 21 +- .../beam/runners/direct/WatermarkManager.java | 50 ++-- .../ConsumerTrackingPipelineVisitorTest.java | 287 ------------------- .../runners/direct/DirectGraphVisitorTest.java | 239 +++++++++++++++ .../runners/direct/EvaluationContextTest.java | 29 +- .../ImmutabilityCheckingBundleFactoryTest.java | 6 +- .../runners/direct/WatermarkManagerTest.java | 23 +- 13 files changed, 575 insertions(+), 613 deletions(-) ----------------------------------------------------------------------