You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/06/27 05:49:34 UTC
[2/2] beam git commit: This closes #3444
This closes #3444
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8036001d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8036001d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8036001d
Branch: refs/heads/master
Commit: 8036001da6f90eac20d787a05d35a51e30146278
Parents: 95e6bbe eb379e7
Author: Ahmet Altay <al...@google.com>
Authored: Mon Jun 26 22:49:19 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Mon Jun 26 22:49:19 2017 -0700
----------------------------------------------------------------------
.../apache_beam/runners/direct/direct_runner.py | 29 +++-
.../runners/direct/evaluation_context.py | 2 +-
.../runners/direct/transform_evaluator.py | 138 ++++++++++++++++++-
sdks/python/apache_beam/runners/direct/util.py | 25 ++--
.../runners/direct/watermark_manager.py | 26 ++--
.../apache_beam/testing/test_stream_test.py | 37 ++++-
sdks/python/apache_beam/transforms/trigger.py | 16 +++
7 files changed, 239 insertions(+), 34 deletions(-)
----------------------------------------------------------------------