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 2017/06/23 03:04:38 UTC
[12/50] beam git commit: This closes #3409
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/gearpump-runner
Commit: f0467b72fd8dfbffaaeb353abfaa1fefa1ee0092
Parents: 28c6fd4 3520f94
Author: Ahmet Altay <al...@google.com>
Authored: Wed Jun 21 13:44:08 2017 -0700
Committer: Ahmet Altay <al...@google.com>
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(-)
----------------------------------------------------------------------