Repository: beam Updated Branches: refs/heads/master dc70383cb -> 19c33dfa6
This closes #3269 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/19c33dfa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/19c33dfa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/19c33dfa Branch: refs/heads/master Commit: 19c33dfa6b8a64a102192c7ff47acc27a0db548a Parents: dc70383 6a78bd3 Author: Thomas Groh <tg...@google.com> Authored: Wed May 31 10:38:45 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Wed May 31 10:38:45 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/direct/DirectGraph.java | 26 +++++++++++--------- .../beam/runners/direct/DirectGraphVisitor.java | 25 ++++++++++--------- .../beam/runners/direct/DirectRunner.java | 4 ++- .../beam/runners/direct/EvaluationContext.java | 17 ++++++++++++- .../beam/runners/direct/WatermarkManager.java | 19 +++++++++++--- .../runners/direct/DirectGraphVisitorTest.java | 3 +++ .../beam/runners/direct/DirectGraphs.java | 10 +++++++- .../runners/direct/EvaluationContextTest.java | 6 ++++- 8 files changed, 80 insertions(+), 30 deletions(-) ----------------------------------------------------------------------
