Interface BroadcastStateBootstrapFunction.Context
-
- Enclosing class:
- BroadcastStateBootstrapFunction<IN>
public static interface BroadcastStateBootstrapFunction.Context
Context thatBroadcastStateBootstrapFunction
's can use for getting additional data about an input record.The context is only valid for the duration of a
BroadcastStateBootstrapFunction.processElement(Object, Context)
call. Do not store the context and use afterwards!
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
currentProcessingTime()
Returns the current processing time.<K,V>
BroadcastState<K,V>getBroadcastState(MapStateDescriptor<K,V> descriptor)
Fetches theBroadcastState
with the specified name.
-
-
-
Method Detail
-
currentProcessingTime
long currentProcessingTime()
Returns the current processing time.
-
getBroadcastState
<K,V> BroadcastState<K,V> getBroadcastState(MapStateDescriptor<K,V> descriptor)
Fetches theBroadcastState
with the specified name.- Parameters:
descriptor
- theMapStateDescriptor
of the state to be fetched.- Returns:
- The required
broadcast state
.
-
-