You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ke...@apache.org on 2016/12/06 16:41:17 UTC

[27/50] [abbrv] incubator-beam git commit: This closes #1487

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/gearpump-runner
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(-)
----------------------------------------------------------------------