@ThreadSafe public class TaskExecutorStateChangelogStoragesManager extends Object
StateChangelogStorage
objects for a task executor (manager).Constructor and Description |
---|
TaskExecutorStateChangelogStoragesManager() |
Modifier and Type | Method and Description |
---|---|
Optional<StateChangelogStorage<?>> |
getChangelogStoragesByJobId(JobID jobId) |
void |
releaseResourcesForJob(JobID jobID) |
void |
shutdown() |
StateChangelogStorage<?> |
stateChangelogStorageForJob(JobID jobId,
Configuration configuration,
TaskManagerJobMetricGroup metricGroup,
LocalRecoveryConfig localRecoveryConfig) |
public TaskExecutorStateChangelogStoragesManager()
@Nullable public StateChangelogStorage<?> stateChangelogStorageForJob(@Nonnull JobID jobId, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig) throws IOException
IOException
public void shutdown()
@VisibleForTesting @Nullable public Optional<StateChangelogStorage<?>> getChangelogStoragesByJobId(JobID jobId)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.