public class TaskExecutorFileMergingManager extends Object
FileMergingSnapshotManager
for each job per task manager. This class holds
all FileMergingSnapshotManager
objects for a task executor (manager).Constructor and Description |
---|
TaskExecutorFileMergingManager() |
Modifier and Type | Method and Description |
---|---|
FileMergingSnapshotManager |
fileMergingSnapshotManagerForTask(JobID jobId,
ResourceID tmResourceId,
ExecutionAttemptID executionAttemptID,
Configuration clusterConfiguration,
Configuration jobConfiguration,
TaskManagerJobMetricGroup metricGroup)
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
org.apache.flink.runtime.taskexecutor.TaskExecutor#releaseJobResources called. |
void |
releaseMergingSnapshotManagerForTask(JobID jobId,
ExecutionAttemptID executionAttemptID) |
void |
shutdown() |
@Nullable public FileMergingSnapshotManager fileMergingSnapshotManagerForTask(@Nonnull JobID jobId, @Nonnull ResourceID tmResourceId, @Nonnull ExecutionAttemptID executionAttemptID, Configuration clusterConfiguration, Configuration jobConfiguration, TaskManagerJobMetricGroup metricGroup)
TaskExecutor.submitTask(org.apache.flink.runtime.deployment.TaskDeploymentDescriptor, org.apache.flink.runtime.jobmaster.JobMasterId, org.apache.flink.api.common.time.Time)
.public void releaseMergingSnapshotManagerForTask(@Nonnull JobID jobId, @Nonnull ExecutionAttemptID executionAttemptID)
public void releaseMergingSnapshotManagerForJob(@Nonnull JobID jobId)
org.apache.flink.runtime.taskexecutor.TaskExecutor#releaseJobResources
called.public void shutdown()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.