beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [2/2] beam git commit: This closes #3409
Date Wed, 21 Jun 2017 20:44:17 GMT
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 <altay@google.com>
Authored: Wed Jun 21 13:44:08 2017 -0700
Committer: Ahmet Altay <altay@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(-)
----------------------------------------------------------------------



Mime
View raw message