org.apache.flink.runtime.state

Class StateCheckpoint<T>

java.lang.Object

org.apache.flink.runtime.state.StateCheckpoint<T>

Type Parameters:

T - The type of the state.

All Implemented Interfaces:

Serializable

public class StateCheckpoint<T>
extends Object
implements Serializable

Base class for creating checkpoints for OperatorState. This checkpoints will be used to backup states in stateful Flink operators and also to restore them in case of node failure. To allow incremental checkpoints override the #update(StateCheckpoint) method.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
OperatorState<T>	checkpointedState

Constructor Summary

Constructors

Constructor and Description
StateCheckpoint(OperatorState<T> operatorState) Creates a state checkpoint from the given OperatorState

Method Summary

Modifier and Type	Method and Description
OperatorState<T>	restore()
boolean	stateEquals(StateCheckpoint<T> other)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

checkpointedState

public OperatorState<T> checkpointedState

Constructor Detail

StateCheckpoint

public StateCheckpoint(OperatorState<T> operatorState)

Creates a state checkpoint from the given OperatorState

Parameters:

operatorState - The OperatorState to checkpoint.

Method Detail

restore

public OperatorState<T> restore()

toString

public String toString()

Overrides:

toString in class Object

stateEquals

public boolean stateEquals(StateCheckpoint<T> other)