[
https://issues.apache.org/jira/browse/BEAM-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16257890#comment-16257890
]
ASF GitHub Bot commented on BEAM-3153:
--------------------------------------
GitHub user mariapython opened a pull request:
https://github.com/apache/beam/pull/4148
[BEAM-3153] Add Python processing-time timers and clock injection
- [x] Add processing-time timers
- [x] Add clock to runners/direct
- [x] Clock injection and propagation:
DirectRunner → EvaluationContext → WatermarkManager
- [x] Use RealClock() for production and TestClock() for tests
- [x] Add mechanism to detect not-yet fired realtime timers
- [x] Refactoring:
_TransformWatermarks’ extract_fired_timers → extract_transform_timers
WatermarkManager’s extract_fired_timers → extract_all_timers
EvaluationContext’s extract_fired_timers → extract_all_timers
- [x] Add and improve comments
- [ ] Tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mariapython/incubator-beam direct-timers-show
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/4148.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4148
----
commit 517fae9dcb749a59322ea40c7de0eb90ebf5efac
Author: Maria Garcia Herrero <mari...@google.com>
Date: 2017-10-20T18:14:54Z
Add Python processing-time timers and clock injection
----
> Allow streaming processing time domain timers in Beam Python DirectRunner
> -------------------------------------------------------------------------
>
> Key: BEAM-3153
> URL: https://issues.apache.org/jira/browse/BEAM-3153
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core
> Reporter: Charles Chen
> Assignee: María GH
>
> Currently, streaming execution in the Python Beam DirectRunner only allows
> for watermark domain timers and does not allow for processing time timers.
> We should support processing time timers, along with a testing framework
> (potentially with a fake clock) that lets us test this behavior using the
> TestStream primitive.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
