You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2017/12/15 01:42:20 UTC
[beam] branch master updated (aba5b0d -> 734b2be)
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from aba5b0d Merge pull request #4255 from robertwb/output-to-receive
add 6bcf84f Add Python processing-time timers and clock injection
add ec7615b Fix linter error
add 516e04c Add review comments
add 679a92d Address review comments
add d1db15d borrar
add 79e167f Add review commnets
new 734b2be Add Python processing-time timers and clock injection
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
sdks/python/apache_beam/runners/direct/clock.py | 37 +++++++++++-----------
.../apache_beam/runners/direct/direct_runner.py | 19 +++++++----
.../runners/direct/evaluation_context.py | 9 +++---
sdks/python/apache_beam/runners/direct/executor.py | 37 +++++++++++++---------
.../runners/direct/watermark_manager.py | 28 ++++++++++------
sdks/python/apache_beam/transforms/trigger.py | 25 ++++++++++++---
6 files changed, 97 insertions(+), 58 deletions(-)
--
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <co...@beam.apache.org>'].
[beam] 01/01: Add Python processing-time timers and clock injection
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 734b2bea94ad1d781a9416e7ec52db6726e3b5e8
Merge: aba5b0d 79e167f
Author: Chamikara Jayalath <ch...@google.com>
AuthorDate: Thu Dec 14 17:42:17 2017 -0800
Add Python processing-time timers and clock injection
[BEAM-3153] Add Python processing-time timers and clock injection
sdks/python/apache_beam/runners/direct/clock.py | 37 +++++++++++-----------
.../apache_beam/runners/direct/direct_runner.py | 19 +++++++----
.../runners/direct/evaluation_context.py | 9 +++---
sdks/python/apache_beam/runners/direct/executor.py | 37 +++++++++++++---------
.../runners/direct/watermark_manager.py | 28 ++++++++++------
sdks/python/apache_beam/transforms/trigger.py | 25 ++++++++++++---
6 files changed, 97 insertions(+), 58 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.