This closes #3409
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f0467b72 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f0467b72 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f0467b72 Branch: refs/heads/master Commit: f0467b72fd8dfbffaaeb353abfaa1fefa1ee0092 Parents: 28c6fd4 3520f94 Author: Ahmet Altay <[email protected]> Authored: Wed Jun 21 13:44:08 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Wed Jun 21 13:44:08 2017 -0700 ---------------------------------------------------------------------- .../runners/direct/evaluation_context.py | 14 ++-- .../apache_beam/runners/direct/executor.py | 40 +++++++-- .../runners/direct/transform_evaluator.py | 88 ++++++++++++++++++-- sdks/python/apache_beam/runners/direct/util.py | 4 +- .../runners/direct/watermark_manager.py | 11 ++- sdks/python/apache_beam/testing/test_stream.py | 5 ++ .../apache_beam/testing/test_stream_test.py | 37 ++++++++ 7 files changed, 176 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
