org.apache.flink.runtime.state

Class OperatorStateRestoreOperation

java.lang.Object

org.apache.flink.runtime.state.OperatorStateRestoreOperation

All Implemented Interfaces:

RestoreOperation<Void>

public class OperatorStateRestoreOperation
extends Object
implements RestoreOperation<Void>

Implementation of operator state restore operation.

Constructor Summary

Constructors

Constructor and Description
OperatorStateRestoreOperation(CloseableRegistry closeStreamOnCancelRegistry, ClassLoader userClassloader, Map<String,PartitionableListState<?>> registeredOperatorStates, Map<String,BackendWritableBroadcastState<?,?>> registeredBroadcastStates, Collection<OperatorStateHandle> stateHandles)

Method Summary

Modifier and Type	Method and Description
Void	restore() Restores state that was previously snapshot-ed from the provided state handles.

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorStateRestoreOperation

public OperatorStateRestoreOperation(CloseableRegistry closeStreamOnCancelRegistry,
                                     ClassLoader userClassloader,
                                     Map<String,PartitionableListState<?>> registeredOperatorStates,
                                     Map<String,BackendWritableBroadcastState<?,?>> registeredBroadcastStates,
                                     @Nonnull
                                     Collection<OperatorStateHandle> stateHandles)

Method Detail

restore

public Void restore()
             throws Exception

Description copied from interface: RestoreOperation

Restores state that was previously snapshot-ed from the provided state handles.

Specified by:

restore in interface RestoreOperation<Void>

Throws:

Exception