org.apache.flink.runtime.checkpoint.filemerging

Class SubtaskFileMergingManagerRestoreOperation

java.lang.Object

org.apache.flink.runtime.checkpoint.filemerging.SubtaskFileMergingManagerRestoreOperation

public class SubtaskFileMergingManagerRestoreOperation
extends Object

Restore operation that restores file-merging information belonging to one subtask for FileMergingSnapshotManager.

Constructor Summary

Constructors

Constructor and Description
SubtaskFileMergingManagerRestoreOperation(long checkpointId, FileMergingSnapshotManager fileMergingSnapshotManager, org.apache.flink.api.common.JobID jobID, org.apache.flink.api.common.TaskInfo taskInfo, JobVertexID vertexID, OperatorSubtaskState subtaskState)

Method Summary

Modifier and Type	Method and Description
void	restore()

Methods inherited from class java.lang.Object

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

Constructor Detail

SubtaskFileMergingManagerRestoreOperation

public SubtaskFileMergingManagerRestoreOperation(long checkpointId,
                                                 FileMergingSnapshotManager fileMergingSnapshotManager,
                                                 org.apache.flink.api.common.JobID jobID,
                                                 org.apache.flink.api.common.TaskInfo taskInfo,
                                                 JobVertexID vertexID,
                                                 OperatorSubtaskState subtaskState)

Method Detail

restore

public void restore()