Package org.apache.flink.runtime.state
Interface CheckpointStateToolset
-
- All Known Implementing Classes:
FsCheckpointStateToolset
,NotDuplicatingCheckpointStateToolset
@Internal public interface CheckpointStateToolset
A toolset of operations that can be performed on a location embedded within the class. Created inCheckpointStorageWorkerView
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
canFastDuplicate(StreamStateHandle stateHandle)
Tells if we can duplicate the givenStreamStateHandle
.List<StreamStateHandle>
duplicate(List<StreamStateHandle> stateHandle)
DuplicatesStreamStateHandles
into the path embedded inside of the class.
-
-
-
Method Detail
-
canFastDuplicate
boolean canFastDuplicate(StreamStateHandle stateHandle) throws IOException
Tells if we can duplicate the givenStreamStateHandle
.This should be a rather cheap operation, preferably not involving any remote accesses.
- Parameters:
stateHandle
- The handle to duplicate- Returns:
- true, if we can perform the duplication
- Throws:
IOException
-
duplicate
List<StreamStateHandle> duplicate(List<StreamStateHandle> stateHandle) throws IOException
DuplicatesStreamStateHandles
into the path embedded inside of the class.You should first check if you can duplicate with
canFastDuplicate(StreamStateHandle)
.- Parameters:
stateHandle
- The handles to duplicate- Returns:
- The duplicated handles
- Throws:
IOException
-
-