org.apache.flink.runtime.dispatcher.cleanup

Interface ResourceCleanerFactory

All Known Implementing Classes:

DispatcherResourceCleanerFactory

public interface ResourceCleanerFactory

ResourceCleanerFactory provides methods to create ResourceCleaner for local and global cleanup.

See Also:

GloballyCleanableResource, LocallyCleanableResource

Method Summary

Modifier and Type	Method and Description
ResourceCleaner	createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) Creates ResourceCleaner that initiates GloballyCleanableResource.globalCleanupAsync(JobID, Executor) calls.
ResourceCleaner	createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor) Creates ResourceCleaner that initiates LocallyCleanableResource.localCleanupAsync(JobID, Executor) calls.

Method Detail

createLocalResourceCleaner

ResourceCleaner createLocalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)

Creates ResourceCleaner that initiates LocallyCleanableResource.localCleanupAsync(JobID, Executor) calls.

Parameters:

mainThreadExecutor - Used for validating that the LocallyCleanableResource.localCleanupAsync(JobID, Executor) is called from the main thread.

createGlobalResourceCleaner

ResourceCleaner createGlobalResourceCleaner(ComponentMainThreadExecutor mainThreadExecutor)

Creates ResourceCleaner that initiates GloballyCleanableResource.globalCleanupAsync(JobID, Executor) calls.

Parameters:

mainThreadExecutor - Used for validating that the GloballyCleanableResource.globalCleanupAsync(JobID, Executor) is called from the main thread.