org.apache.flink.runtime.state

Class TaskExecutorFileMergingManager

java.lang.Object

org.apache.flink.runtime.state.TaskExecutorFileMergingManager

public class TaskExecutorFileMergingManager
extends Object

There is one FileMergingSnapshotManager for each job per task manager. This class holds all FileMergingSnapshotManager objects for a task executor (manager).

Constructor Summary

Constructors

Constructor and Description
TaskExecutorFileMergingManager()

Method Summary

Modifier and Type	Method and Description
FileMergingSnapshotManager	fileMergingSnapshotManagerForJob(JobID jobId) Initialize file merging snapshot manager for each job according configurations when TaskExecutor.submitTask(org.apache.flink.runtime.deployment.TaskDeploymentDescriptor, org.apache.flink.runtime.jobmaster.JobMasterId, org.apache.flink.api.common.time.Time).
void	releaseMergingSnapshotManagerForJob(JobID jobId) Release file merging snapshot manager of one job when TaskExecutor.releaseJobResources(org.apache.flink.api.common.JobID, java.lang.Exception) called.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutorFileMergingManager

public TaskExecutorFileMergingManager()

Method Detail

fileMergingSnapshotManagerForJob

@Nullable
public FileMergingSnapshotManager fileMergingSnapshotManagerForJob(@Nonnull
                                                                             JobID jobId)

Initialize file merging snapshot manager for each job according configurations when TaskExecutor.submitTask(org.apache.flink.runtime.deployment.TaskDeploymentDescriptor, org.apache.flink.runtime.jobmaster.JobMasterId, org.apache.flink.api.common.time.Time).

releaseMergingSnapshotManagerForJob

public void releaseMergingSnapshotManagerForJob(@Nonnull
                                                JobID jobId)

Release file merging snapshot manager of one job when TaskExecutor.releaseJobResources(org.apache.flink.api.common.JobID, java.lang.Exception) called.

shutdown

public void shutdown()