org.apache.flink.runtime.state

Interface FunctionInitializationContext

All Superinterfaces:

ManagedInitializationContext

All Known Subinterfaces:

StateInitializationContext

All Known Implementing Classes:

StateInitializationContextImpl

@PublicEvolving
public interface FunctionInitializationContext
extends ManagedInitializationContext

This interface provides a context in which user functions can initialize by registering to managed state (i.e. state that is managed by state backends).

Operator state is available to all functions, while keyed state is only available for functions after keyBy.

For the purpose of initialization, the context signals if the state is empty or was restored from a previous execution.

Method Summary

Methods inherited from interface org.apache.flink.runtime.state.ManagedInitializationContext

getKeyedStateStore, getOperatorStateStore, isRestored