You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ro...@apache.org on 2018/02/15 21:19:02 UTC

[beam] 01/01: Merge pull request #4425 from [BEAM-3153] Add processing-time timers for the DirectRunner.

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 77ecbc7d885ebd67f36022fb1dd8c7a17f6ebc3b
Merge: a5d9fe1 4f681ee
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Thu Feb 15 13:18:57 2018 -0800

    Merge pull request #4425 from [BEAM-3153] Add processing-time timers for the DirectRunner.
    
    [BEAM-3153] Add processing-time timers for the DirectRunner.

 sdks/python/apache_beam/runners/direct/executor.py |  17 +--
 .../runners/direct/transform_evaluator.py          |   7 +-
 sdks/python/apache_beam/runners/direct/util.py     |   5 +
 .../python/apache_beam/testing/test_stream_test.py | 102 ++++++++++++++++-
 sdks/python/apache_beam/transforms/trigger.py      | 123 ++++++++++++++++-----
 sdks/python/apache_beam/transforms/trigger_test.py |   3 +-
 6 files changed, 215 insertions(+), 42 deletions(-)


-- 
To stop receiving notification emails like this one, please contact
robertwb@apache.org.