[BEAM-7155] Provide access to <K> within DoFn.OnTimerContext

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.11.0
• Component/s: sdk-java-core
• Labels: Clarified
• Assignee: Unassigned
• Reporter: Reza ardeshir rokni
• Created: 26/Apr/19 01:22
• Updated: 04/Jun/22 01:52

Description

org.apache.beam.sdk.transforms.DoFn.OnTimerContext Does not support access to Key. Current workaround:

@ProcessElement 

@StateId("dataKey") ValueState<String> key

{ key.write(key)}

 

...

 

@OnTimer("processTimer") public void OnTimer(OnTimerContext otc,
@StateId("dataKey") ValueState<String> key,

{key.read()}