Uses of Class
org.apache.flink.runtime.state.filemerging.SegmentFileStateHandle
-
Packages that use SegmentFileStateHandle Package Description org.apache.flink.runtime.checkpoint.filemerging org.apache.flink.runtime.state.filemerging org.apache.flink.runtime.state.filesystem -
-
Uses of SegmentFileStateHandle in org.apache.flink.runtime.checkpoint.filemerging
Method parameters in org.apache.flink.runtime.checkpoint.filemerging with type arguments of type SegmentFileStateHandle Modifier and Type Method Description void
FileMergingSnapshotManager. restoreStateHandles(long checkpointId, FileMergingSnapshotManager.SubtaskKey subtaskKey, Stream<SegmentFileStateHandle> stateHandles)
Restore and re-register the SegmentFileStateHandles into FileMergingSnapshotManager.void
FileMergingSnapshotManagerBase. restoreStateHandles(long checkpointId, FileMergingSnapshotManager.SubtaskKey subtaskKey, Stream<SegmentFileStateHandle> stateHandles)
-
Uses of SegmentFileStateHandle in org.apache.flink.runtime.state.filemerging
Subclasses of SegmentFileStateHandle in org.apache.flink.runtime.state.filemerging Modifier and Type Class Description class
EmptySegmentFileStateHandle
An emptySegmentFileStateHandle
that is only used as a placeholder. -
Uses of SegmentFileStateHandle in org.apache.flink.runtime.state.filesystem
Methods in org.apache.flink.runtime.state.filesystem that return SegmentFileStateHandle Modifier and Type Method Description SegmentFileStateHandle
FileMergingCheckpointStateOutputStream. closeAndGetHandle()
SegmentFileStateHandle
FileMergingCheckpointStateOutputStream.FileMergingSnapshotManagerProxy. closeStreamAndCreateStateHandle(Path filePath, long startPos, long stateSize)
Close the stream and create aSegmentFileStateHandle
for a file segment.
-