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