Uses of Class
org.apache.flink.runtime.checkpoint.filemerging.PhysicalFile

Packages that use PhysicalFile

Package	Description
org.apache.flink.runtime.checkpoint.filemerging

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

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

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.
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)
PhysicalFile	LogicalFile.getPhysicalFile()

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

Modifier and Type	Method	Description
protected LogicalFile	FileMergingSnapshotManagerBase.createLogicalFile(PhysicalFile physicalFile, long startOffset, long length, FileMergingSnapshotManager.SubtaskKey subtaskKey)	Create a logical file on a physical file.
protected abstract void	FileMergingSnapshotManagerBase.returnPhysicalFileForNextReuse(FileMergingSnapshotManager.SubtaskKey subtaskKey, long checkpointId, PhysicalFile physicalFile)	Try to return an existing physical file to the manager for next reuse.
protected void	WithinCheckpointFileMergingSnapshotManager.returnPhysicalFileForNextReuse(FileMergingSnapshotManager.SubtaskKey subtaskKey, long checkpointId, PhysicalFile physicalFile)

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

Constructor	Description
LogicalFile(LogicalFile.LogicalFileId fileId, PhysicalFile physicalFile, long startOffset, long length, FileMergingSnapshotManager.SubtaskKey subtaskKey)