Interface ExecutionGraphCache
-
- All Superinterfaces:
AutoCloseable
,Closeable
- All Known Implementing Classes:
DefaultExecutionGraphCache
public interface ExecutionGraphCache extends Closeable
Cache forExecutionGraphInfo
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 theExecutionGraphInfo
from the cluster.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cleanup()
Perform the cleanup of out dated cache entries.void
close()
Closes the execution graph cache.CompletableFuture<ExecutionGraphInfo>
getExecutionGraphInfo(JobID jobId, RestfulGateway restfulGateway)
Gets theExecutionGraphInfo
for the givenJobID
and caches it.int
size()
Gets the number of cache entries.
-
-
-
Method Detail
-
size
int size()
Gets the number of cache entries.
-
getExecutionGraphInfo
CompletableFuture<ExecutionGraphInfo> getExecutionGraphInfo(JobID jobId, RestfulGateway restfulGateway)
Gets theExecutionGraphInfo
for the givenJobID
and caches it. TheExecutionGraphInfo
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 theExecutionGraphInfo
to getrestfulGateway
- to request theExecutionGraphInfo
from- Returns:
- Future containing the requested
ExecutionGraphInfo
-
cleanup
void cleanup()
Perform the cleanup of out dated cache entries.
-
close
void close()
Closes the execution graph cache.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-
-