This closes #2570
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4ce94f4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4ce94f4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4ce94f4 Branch: refs/heads/master Commit: d4ce94f4e3aac12b78b48c34e6567f19f3eb53b2 Parents: 4f0146a 4d98d43 Author: Ahmet Altay <[email protected]> Authored: Tue Apr 18 09:32:04 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Tue Apr 18 09:32:04 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/direct/clock.py | 9 ++-- .../runners/direct/evaluation_context.py | 11 ++--- .../apache_beam/runners/direct/executor.py | 4 +- .../runners/direct/transform_result.py | 45 +++++--------------- .../runners/direct/watermark_manager.py | 4 +- 5 files changed, 23 insertions(+), 50 deletions(-) ----------------------------------------------------------------------
