org.apache.flink.state.api.functions

Interface BroadcastStateBootstrapFunction.Context

Enclosing class:

BroadcastStateBootstrapFunction<IN>

public static interface BroadcastStateBootstrapFunction.Context

Context that BroadcastStateBootstrapFunction'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

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
<K,V> BroadcastState<K,V>	getBroadcastState(MapStateDescriptor<K,V> descriptor) Fetches the BroadcastState 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 the BroadcastState with the specified name.

Parameters:

descriptor - the MapStateDescriptor of the state to be fetched.

Returns:

The required broadcast state.