Package 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.