Uses of Class
org.apache.flink.runtime.state.CheckpointedStateScope

Packages that use CheckpointedStateScope

Package	Description
org.apache.flink.runtime.checkpoint.filemerging
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.memory

Uses of CheckpointedStateScope in org.apache.flink.runtime.checkpoint.filemerging

Methods in org.apache.flink.runtime.checkpoint.filemerging that return CheckpointedStateScope

Modifier and Type	Method	Description
CheckpointedStateScope	PhysicalFile.getScope()

Methods in org.apache.flink.runtime.checkpoint.filemerging with parameters of type CheckpointedStateScope

Modifier and Type	Method	Description
protected PhysicalFile	FileMergingSnapshotManagerBase.createPhysicalFile(FileMergingSnapshotManager.SubtaskKey subtaskKey, CheckpointedStateScope scope)	Create a physical file in right location (managed directory), which is specified by scope of this checkpoint and current subtask.
org.apache.flink.core.fs.Path	FileMergingSnapshotManager.getManagedDir(FileMergingSnapshotManager.SubtaskKey subtaskKey, CheckpointedStateScope scope)	Get the managed directory of the file-merging snapshot manager, created in FileMergingSnapshotManager.initFileSystem(org.apache.flink.core.fs.FileSystem, org.apache.flink.core.fs.Path, org.apache.flink.core.fs.Path, org.apache.flink.core.fs.Path) or FileMergingSnapshotManager.registerSubtaskForSharedStates(org.apache.flink.runtime.checkpoint.filemerging.FileMergingSnapshotManager.SubtaskKey).
org.apache.flink.core.fs.Path	FileMergingSnapshotManagerBase.getManagedDir(FileMergingSnapshotManager.SubtaskKey subtaskKey, CheckpointedStateScope scope)
protected abstract PhysicalFile	FileMergingSnapshotManagerBase.getOrCreatePhysicalFileForCheckpoint(FileMergingSnapshotManager.SubtaskKey subtaskKey, long checkpointId, CheckpointedStateScope scope)	Get a reused physical file or create one.
protected PhysicalFile	WithinCheckpointFileMergingSnapshotManager.getOrCreatePhysicalFileForCheckpoint(FileMergingSnapshotManager.SubtaskKey subtaskKey, long checkpointId, CheckpointedStateScope scope)

Constructors in org.apache.flink.runtime.checkpoint.filemerging with parameters of type CheckpointedStateScope

Constructor	Description
PhysicalFile(org.apache.flink.core.fs.FSDataOutputStream outputStream, org.apache.flink.core.fs.Path filePath, PhysicalFile.PhysicalFileDeleter deleter, CheckpointedStateScope scope)

Uses of CheckpointedStateScope in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return CheckpointedStateScope

Modifier and Type	Method	Description
static CheckpointedStateScope	CheckpointedStateScope.valueOf(String name)	Returns the enum constant of this type with the specified name.
static CheckpointedStateScope[]	CheckpointedStateScope.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.runtime.state with parameters of type CheckpointedStateScope

Modifier and Type	Method	Description
boolean	CheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle, CheckpointedStateScope scope)	Tells if we can duplicate the given StreamStateHandle into the path corresponding to the given CheckpointedStateScope.
CheckpointStateOutputStream	CheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)	Creates an new CheckpointStateOutputStream.
static CheckpointStreamWithResultProvider	CheckpointStreamWithResultProvider.createDuplicatingStream(long checkpointId, CheckpointedStateScope checkpointedStateScope, CheckpointStreamFactory primaryStreamFactory, LocalRecoveryDirectoryProvider secondaryStreamDirProvider)
static CheckpointStreamWithResultProvider	CheckpointStreamWithResultProvider.createSimpleStream(CheckpointedStateScope checkpointedStateScope, CheckpointStreamFactory primaryStreamFactory)
List<StreamStateHandle>	CheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles, CheckpointedStateScope scope)	Duplicates StreamStateHandle into the path corresponding to * the given CheckpointedStateScope.

Uses of CheckpointedStateScope in org.apache.flink.runtime.state.filesystem

Methods in org.apache.flink.runtime.state.filesystem with parameters of type CheckpointedStateScope

Modifier and Type	Method	Description
boolean	FsCheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle, CheckpointedStateScope scope)
FsCheckpointStreamFactory.FsCheckpointStateOutputStream	FsCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)
List<StreamStateHandle>	FsCheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles, CheckpointedStateScope scope)

Uses of CheckpointedStateScope in org.apache.flink.runtime.state.memory

Methods in org.apache.flink.runtime.state.memory with parameters of type CheckpointedStateScope

Modifier and Type	Method	Description
boolean	MemCheckpointStreamFactory.canFastDuplicate(StreamStateHandle stateHandle, CheckpointedStateScope scope)
CheckpointStateOutputStream	MemCheckpointStreamFactory.createCheckpointStateOutputStream(CheckpointedStateScope scope)
List<StreamStateHandle>	MemCheckpointStreamFactory.duplicate(List<StreamStateHandle> stateHandles, CheckpointedStateScope scope)