org.apache.flink.streaming.api.functions.co

Class KeyedBroadcastProcessFunction.Context

java.lang.Object

org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction.Context

org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction.Context

Enclosing class:

KeyedBroadcastProcessFunction<KS,IN1,IN2,OUT>

public abstract class KeyedBroadcastProcessFunction.Context
extends BaseBroadcastProcessFunction.Context

A context available to the broadcast side of a BroadcastConnectedStream.

Apart from the basic functionality of a context, this also allows to apply a KeyedStateFunction to the (local) states of all active keys in the your backend.

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and Description
abstract <VS,S extends State> void	applyToKeyedState(StateDescriptor<S,VS> stateDescriptor, KeyedStateFunction<KS,S> function) Applies the provided function to the state associated with the provided state descriptor.
abstract long	currentProcessingTime() Returns the current processing time.
abstract long	currentWatermark() Returns the current event-time watermark.
abstract <X> void	output(OutputTag<X> outputTag, X value) Emits a record to the side output identified by the OutputTag.
abstract Long	timestamp() Timestamp of the element currently being processed or timestamp of a firing timer.

Methods inherited from class org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction.Context

getBroadcastState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Context

public Context()

Method Detail

applyToKeyedState

public abstract <VS,S extends State> void applyToKeyedState(StateDescriptor<S,VS> stateDescriptor,
                                                            KeyedStateFunction<KS,S> function)
                                                     throws Exception

Applies the provided function to the state associated with the provided state descriptor.

Parameters:

stateDescriptor - the descriptor of the state to be processed.

function - the function to be applied.

Throws:

Exception

timestamp

public abstract Long timestamp()

Timestamp of the element currently being processed or timestamp of a firing timer.

This might be null, for example if the time characteristic of your program is set to TimeCharacteristic.ProcessingTime.

output

public abstract <X> void output(OutputTag<X> outputTag,
                                X value)

Emits a record to the side output identified by the OutputTag.

Parameters:

outputTag - the OutputTag that identifies the side output to emit to.

value - The record to emit.

currentProcessingTime

public abstract long currentProcessingTime()

Returns the current processing time.

currentWatermark

public abstract long currentWatermark()

Returns the current event-time watermark.