org.apache.flink.runtime.dispatcher

Class DispatcherOperationCaches

java.lang.Object

org.apache.flink.runtime.dispatcher.DispatcherOperationCaches

public class DispatcherOperationCaches
extends Object

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
CompletedOperationCache<AsynchronousJobOperationKey,String>	getSavepointTriggerCache()
CompletableFuture<Void>	shutdownCaches()

Methods inherited from class java.lang.Object

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

Constructor Detail

DispatcherOperationCaches

@VisibleForTesting
public DispatcherOperationCaches()

DispatcherOperationCaches

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

Method Detail

getSavepointTriggerCache

public CompletedOperationCache<AsynchronousJobOperationKey,String> getSavepointTriggerCache()

shutdownCaches

public CompletableFuture<Void> shutdownCaches()