Package | Description |
---|---|
org.apache.flink.runtime.dispatcher.cleanup |
Modifier and Type | Class and Description |
---|---|
class |
DefaultResourceCleaner<T>
DefaultResourceCleaner is the default implementation of ResourceCleaner . |
Modifier and Type | Method and Description |
---|---|
ResourceCleaner |
DispatcherResourceCleanerFactory.createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) |
ResourceCleaner |
ResourceCleanerFactory.createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)
Creates
ResourceCleaner that initiates GloballyCleanableResource.globalCleanupAsync(JobID, Executor) calls. |
ResourceCleaner |
DispatcherResourceCleanerFactory.createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) |
ResourceCleaner |
ResourceCleanerFactory.createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)
Creates
ResourceCleaner that initiates LocallyCleanableResource.localCleanupAsync(JobID, Executor) calls. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.