Package org.apache.flink.state.api.functions

Class BroadcastStateBootstrapFunction<IN>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.state.api.functions.BroadcastStateBootstrapFunction<IN>

Type Parameters:

IN - The type of the input.

All Implemented Interfaces:

Serializable, Function, RichFunction

@PublicEvolving
public abstract class BroadcastStateBootstrapFunction<IN>
extends AbstractRichFunction

Interface for writing elements to broadcast state.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BroadcastStateBootstrapFunction.Context	Context that BroadcastStateBootstrapFunction's can use for getting additional data about an input record.

Constructor Summary

Constructors

Constructor	Description
BroadcastStateBootstrapFunction()

Method Summary

Modifier and Type	Method	Description
abstract void	processElement(IN value, BroadcastStateBootstrapFunction.Context ctx)	Writes the given value to operator state.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastStateBootstrapFunction

public BroadcastStateBootstrapFunction()

Method Detail

processElement

public abstract void processElement(IN value,
                                    BroadcastStateBootstrapFunction.Context ctx)
                             throws Exception

Writes the given value to operator state. This function is called for every record.

Parameters:

value - The input record.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.