DispatcherOperationCaches (Flink : 2.0-SNAPSHOT API)

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 Description

DispatcherOperationCaches()

DispatcherOperationCaches(Duration cacheDuration)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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(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