Reza ardeshir rokni created BEAM-7155:
-----------------------------------------
Summary: Provide access to <K> within DoFn.OnTimerContext
Key: BEAM-7155
URL: https://issues.apache.org/jira/browse/BEAM-7155
Project: Beam
Issue Type: Improvement
Components: sdk-java-core
Affects Versions: 2.11.0
Reporter: Reza ardeshir rokni
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()}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
