Package org.apache.beam.sdk.transforms
Annotation Type DoFn.OnTimerFamily
-
@Documented @Retention(RUNTIME) @Target(METHOD) @Experimental(TIMERS) public static @interface DoFn.OnTimerFamily
Annotation for registering a callback for a timerFamily.See the javadoc for
DoFn.TimerFamily
for use in a full example.The method annotated with
@OnTimerFamily
may have parameters according to the same logic asDoFn.ProcessElement
, but limited to theBoundedWindow
,State
subclasses, andTimerMap
. State and timer parameters must be annotated with theirDoFn.StateId
andDoFn.TimerId
respectively.
-
-
Required Element Summary
Required Elements Modifier and Type Required Element Description java.lang.String
value
The timer ID.
-