org.apache.flink.runtime.state

Interface StateHandleProvider<T>

All Superinterfaces:

Serializable

public interface StateHandleProvider<T>
extends Serializable

Stateful streaming operators use a StateHandleProvider to create new StateHandles to store each checkpoint in a persistent storage layer.

Method Summary

Modifier and Type	Method and Description
StateHandle<T>	createStateHandle(T state) Creates a new StateHandle instance that will be used to store the state checkpoint.

Method Detail

createStateHandle

StateHandle<T> createStateHandle(T state)

Creates a new StateHandle instance that will be used to store the state checkpoint. This method is called for each state checkpoint saved.

Parameters:

state - State to be stored in the handle.