org.apache.flink.runtime.dispatcher

Class DispatcherOperationCaches

java.lang.Object

org.apache.flink.runtime.dispatcher.DispatcherOperationCaches

All Implemented Interfaces:

AutoCloseable, AutoCloseableAsync

public class DispatcherOperationCaches
extends Object
implements AutoCloseableAsync

Encapsulates caches for results of asynchronous operations triggered by the Dispatcher.

Constructor Summary

Constructors

Constructor and Description
DispatcherOperationCaches()
DispatcherOperationCaches(java.time.Duration cacheDuration)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
CompletedOperationCache<AsynchronousJobOperationKey,Long>	getCheckpointTriggerCache()
CompletedOperationCache<AsynchronousJobOperationKey,String>	getSavepointTriggerCache()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Constructor Detail

DispatcherOperationCaches

@VisibleForTesting
public DispatcherOperationCaches()

DispatcherOperationCaches

@VisibleForTesting
public DispatcherOperationCaches(java.time.Duration cacheDuration)

Method Detail

getSavepointTriggerCache

public CompletedOperationCache<AsynchronousJobOperationKey,String> getSavepointTriggerCache()

getCheckpointTriggerCache

public CompletedOperationCache<AsynchronousJobOperationKey,Long> getCheckpointTriggerCache()

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed