org.apache.flink.streaming.api.operators

Interface StreamTaskStateInitializer

All Known Implementing Classes:

StreamTaskStateInitializerImpl

public interface StreamTaskStateInitializer

This is the interface through which stream task expose a StreamOperatorStateContext to their operators. Operators, in turn, can use the context to initialize everything connected to their state, such as backends or a timer service manager.

Method Summary

Modifier and Type	Method and Description
StreamOperatorStateContext	streamOperatorStateContext(OperatorID operatorID, String operatorClassName, KeyContext keyContext, TypeSerializer<?> keySerializer, CloseableRegistry streamTaskCloseableRegistry) Returns the StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream task that owns this manager.

Method Detail

streamOperatorStateContext

StreamOperatorStateContext streamOperatorStateContext(@Nonnull
                                                      OperatorID operatorID,
                                                      @Nonnull
                                                      String operatorClassName,
                                                      @Nonnull
                                                      KeyContext keyContext,
                                                      @Nullable
                                                      TypeSerializer<?> keySerializer,
                                                      @Nonnull
                                                      CloseableRegistry streamTaskCloseableRegistry)
                                               throws Exception

Returns the StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream task that owns this manager.

Parameters:

operatorID - the id of the operator for which the context is created. Cannot be null.

operatorClassName - the classname of the operator instance for which the context is created. Cannot be null.

keyContext - the key context of the operator instance for which the context is created Cannot be null.

keySerializer - the key-serializer for the operator. Can be null.

streamTaskCloseableRegistry - the closeable registry to which created closeable objects will be registered.

Returns:

a context from which the given operator can initialize everything related to state.

Throws:

Exception - when something went wrong while creating the context.