org.apache.flink.runtime.rest.handler.legacy

Class ExecutionGraphCache

java.lang.Object

org.apache.flink.runtime.rest.handler.legacy.ExecutionGraphCache

All Implemented Interfaces:

Closeable, AutoCloseable

public class ExecutionGraphCache
extends Object
implements Closeable

Cache for AccessExecutionGraph which are obtained from the Flink cluster. Every cache entry has an associated time to live after which a new request will trigger the reloading of the AccessExecutionGraph from the cluster.

Constructor Summary

Constructors

Constructor and Description
ExecutionGraphCache(Time timeout, Time timeToLive)

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform the cleanup of out dated ExecutionGraphEntry.
void	close()
CompletableFuture<AccessExecutionGraph>	getExecutionGraph(JobID jobId, RestfulGateway restfulGateway) Gets the AccessExecutionGraph for the given JobID and caches it.
int	size() Gets the number of cache entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionGraphCache

public ExecutionGraphCache(Time timeout,
                           Time timeToLive)

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

size

public int size()

Gets the number of cache entries.

getExecutionGraph

public CompletableFuture<AccessExecutionGraph> getExecutionGraph(JobID jobId,
                                                                 RestfulGateway restfulGateway)

Gets the AccessExecutionGraph for the given JobID and caches it. The AccessExecutionGraph will be requested again after the refresh interval has passed or if the graph could not be retrieved from the given gateway.

Parameters:

jobId - identifying the AccessExecutionGraph to get

restfulGateway - to request the AccessExecutionGraph from

Returns:

Future containing the requested AccessExecutionGraph

cleanup

public void cleanup()

Perform the cleanup of out dated ExecutionGraphEntry.