org.apache.flink.runtime.jobgraph.tasks

Interface OperatorStateCarrier<T extends StateHandle<?>>

public interface OperatorStateCarrier<T extends StateHandle<?>>

This interface must be implemented by any invokable that has recoverable state. The method setInitialState(org.apache.flink.runtime.state.StateHandle) is used to set the initial state of the operator, upon recovery.

Method Summary

Modifier and Type	Method and Description
void	setInitialState(T stateHandle) Sets the initial state of the operator, upon recovery.

Method Detail

setInitialState

void setInitialState(T stateHandle)
              throws Exception

Sets the initial state of the operator, upon recovery. The initial state is typically a snapshot of the state from a previous execution.

Parameters:

stateHandle - The handle to the state.

Throws:

Exception