[BEAM-2925] Fn API user timer support

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.22.0
• Component/s: beam-model
• Labels: portability stale-assigned
• Assignee: Luke Cwik
• Reporter: Henning Rohde
• Created: 12/Sep/17 00:10
• Updated: 10/Jun/20 18:38
• Resolved: 10/Jun/20 18:38

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.

Issue Links

• depends upon: BEAM-2535 Allow explicit output time independent of firing specification for all timers

Sub-Tasks

• Define well known timer URN: Resolved
• Add well known timer coder for Java SDK: Resolved
• Add well known timer coder for Python SDK: Resolved
• Java SDK harness should support user timers: Resolved
• Python SDK harness should support user timers: Resolved
• Update pipeline translation for timers inside Java SDK: Resolved
• Update pipeline translation for timers inside Python SDK: Resolved
• Update pipeline representation in runner support libraries to handle timers: Resolved
• Integrate support for timers using the portability APIs into ULR: Resolved
• Integrate support for timers using the portability APIs into Flink: Resolved
• Integrate support for timers using the portability APIs into Dataflow: Resolved
• Integrate support for timers using the portability APIs into Spark: Resolved