Uses of Interface
org.apache.flink.streaming.api.operators.StreamTaskStateInitializer

Packages that use StreamTaskStateInitializer

Package	Description
org.apache.flink.runtime.asyncprocessing.operators
org.apache.flink.state.api.output.operators
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of StreamTaskStateInitializer in org.apache.flink.runtime.asyncprocessing.operators

Methods in org.apache.flink.runtime.asyncprocessing.operators with parameters of type StreamTaskStateInitializer

Modifier and Type	Method	Description
void	AbstractAsyncStateStreamOperator.initializeState(StreamTaskStateInitializer streamTaskStateManager)	Initialize necessary state components for AbstractStreamOperator.
void	AbstractAsyncStateStreamOperatorV2.initializeState(StreamTaskStateInitializer streamTaskStateManager)	Initialize necessary state components for AbstractStreamOperatorV2.

Uses of StreamTaskStateInitializer in org.apache.flink.state.api.output.operators

Methods in org.apache.flink.state.api.output.operators with parameters of type StreamTaskStateInitializer

Modifier and Type	Method	Description
void	StateBootstrapWrapperOperator.initializeState(StreamTaskStateInitializer streamTaskStateManager)

Uses of StreamTaskStateInitializer in org.apache.flink.streaming.api.operators

Classes in org.apache.flink.streaming.api.operators that implement StreamTaskStateInitializer

Modifier and Type	Class	Description
class	StreamTaskStateInitializerImpl	This class is the main implementation of a StreamTaskStateInitializer.

Methods in org.apache.flink.streaming.api.operators with parameters of type StreamTaskStateInitializer

Modifier and Type	Method	Description
void	AbstractStreamOperator.initializeState(StreamTaskStateInitializer streamTaskStateManager)
void	AbstractStreamOperatorV2.initializeState(StreamTaskStateInitializer streamTaskStateManager)
void	StreamOperator.initializeState(StreamTaskStateInitializer streamTaskStateManager)	Provides a context to initialize all state in the operator.

Uses of StreamTaskStateInitializer in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks that return StreamTaskStateInitializer

Modifier and Type	Method	Description
StreamTaskStateInitializer	StreamTask.createStreamTaskStateInitializer(SubTaskInitializationMetricsBuilder initializationMetrics)

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type StreamTaskStateInitializer

Modifier and Type	Method	Description
void	FinishedOperatorChain.initializeStateAndOpenOperators(StreamTaskStateInitializer streamTaskStateInitializer)
abstract void	OperatorChain.initializeStateAndOpenOperators(StreamTaskStateInitializer streamTaskStateInitializer)	Initialize state and open all operators in the chain from tail to heads, contrary to StreamOperator.close() which happens heads to tail (see OperatorChain.finishOperators(StreamTaskActionExecutor, StopMode)).
void	RegularOperatorChain.initializeStateAndOpenOperators(StreamTaskStateInitializer streamTaskStateInitializer)