Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
Description
Design doc: https://s.apache.org/beam-portability-timers
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.
Attachments
Issue Links
- depends upon
-
BEAM-2535 Allow explicit output time independent of firing specification for all timers
-
- Resolved
-
1.
|
Define well known timer URN |
|
Resolved | Luke Cwik |
|
|||||||
2.
|
Add well known timer coder for Java SDK |
|
Resolved | Luke Cwik |
|
|||||||
3.
|
Add well known timer coder for Python SDK |
|
Resolved | Robert Bradshaw | ||||||||
4.
|
Java SDK harness should support user timers |
|
Resolved | Luke Cwik |
|
|||||||
5.
|
Python SDK harness should support user timers |
|
Resolved | Boyuan Zhang | ||||||||
6.
|
Update pipeline translation for timers inside Java SDK |
|
Resolved | Luke Cwik |
|
|||||||
7.
|
Update pipeline translation for timers inside Python SDK |
|
Resolved | Boyuan Zhang | ||||||||
8.
|
Update pipeline representation in runner support libraries to handle timers |
|
Resolved | Luke Cwik |
|
|||||||
9.
|
Integrate support for timers using the portability APIs into ULR |
|
Resolved | Daniel Oliveira | ||||||||
10.
|
Integrate support for timers using the portability APIs into Flink |
|
Resolved | Maximilian Michels |
|
|||||||
11.
|
Integrate support for timers using the portability APIs into Dataflow |
|
Resolved | Yichi Zhang | ||||||||
12.
|
Integrate support for timers using the portability APIs into Spark |
|
Resolved | Unassigned |
