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

Interface ExecutionGraphCache

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

DefaultExecutionGraphCache

public interface ExecutionGraphCache
extends Closeable

Cache for ArchivedExecutionGraph 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 ArchivedExecutionGraph from the cluster.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform the cleanup of out dated cache entries.
void	close() Closes the execution graph cache.
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.

Method Detail

size

int size()

Gets the number of cache entries.

getExecutionGraph

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 ArchivedExecutionGraph to get

restfulGateway - to request the ArchivedExecutionGraph from

Returns:

Future containing the requested ArchivedExecutionGraph

cleanup

void cleanup()

Perform the cleanup of out dated cache entries.

close

void close()

Closes the execution graph cache.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable