public interface ExecutionGraphCache extends Closeable
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.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.
|
int size()
CompletableFuture<AccessExecutionGraph> getExecutionGraph(JobID jobId, RestfulGateway restfulGateway)
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.jobId
- identifying the ArchivedExecutionGraph
to getrestfulGateway
- to request the ArchivedExecutionGraph
fromArchivedExecutionGraph
void cleanup()
void close()
close
in interface AutoCloseable
close
in interface Closeable
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.