public interface ExecutionGraphCache extends Closeable
ExecutionGraphInfowhich 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
ExecutionGraphInfofrom the cluster.
|Modifier and Type||Method and Description|
Perform the cleanup of out dated cache entries.
Closes the execution graph cache.
Gets the number of cache entries.
CompletableFuture<ExecutionGraphInfo> getExecutionGraphInfo(JobID jobId, RestfulGateway restfulGateway)
ExecutionGraphInfofor the given
JobIDand caches it. The
ExecutionGraphInfowill be requested again after the refresh interval has passed or if the graph could not be retrieved from the given gateway.
jobId- identifying the
restfulGateway- to request the
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.