-
Type:
Improvement
-
Status: In Progress
-
Priority:
Minor
-
Resolution: Unresolved
-
Affects Version/s: None
-
Fix Version/s: None
-
Component/s: beam-model
-
Labels:
Design doc: https://s.apache.org/beam-portability-timers
TODO: Add sub tasks to get timer support into all existing runners.
The FnAPI should support user timers. Design TBD. Some discussions are in https://s.apache.org/beam-state. The most important current feature is the watermark hold (BEAM-2535).
Once design is ready, expand subtasks similarly to BEAM-2822.
- depends upon
-
BEAM-2535 Allow explicit output time independent of firing specification for all timers
-
- In Progress
-
1.
|
Add well known timer coder for Python SDK |
|
Open | Unassigned |
2.
|
Python SDK harness should support user timers |
|
Open | Unassigned |
3.
|
Update pipeline translation for timers inside Python SDK |
|
Open | Unassigned |
4.
|
Integrate support for timers using the portability APIs into Dataflow |
|
Open | Unassigned |
