public class ExecutionGraphHolder extends Object
ExecutionGraph
from a source, like JobManager or Archive.
The holder will cache the ExecutionGraph behind a weak reference, which will be cleared at some point once no one else is pointing to the ExecutionGraph. Note that while the holder runs in the same JVM as the JobManager or Archive, the reference should stay valid.
Constructor and Description |
---|
ExecutionGraphHolder() |
ExecutionGraphHolder(scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
AccessExecutionGraph |
getExecutionGraph(JobID jid,
ActorGateway jobManager)
Retrieves the execution graph with
JobID jid or null if it cannot be found. |
public ExecutionGraphHolder()
public ExecutionGraphHolder(scala.concurrent.duration.FiniteDuration timeout)
public AccessExecutionGraph getExecutionGraph(JobID jid, ActorGateway jobManager)
JobID
jid or null if it cannot be found.jid
- jobID of the execution graph to be retrievedCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.