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