Package | Description |
---|---|
org.apache.flink.runtime.jobmanager |
Modifier and Type | Method and Description |
---|---|
JobInfo |
JobInfo$.apply(akka.actor.ActorRef client,
ListeningBehaviour listeningBehaviour,
long start,
long sessionTimeout) |
static JobInfo |
JobInfo.apply(akka.actor.ActorRef client,
ListeningBehaviour listeningBehaviour,
long start,
long sessionTimeout) |
JobInfo |
SubmittedJobGraph.getJobInfo()
|
Modifier and Type | Method and Description |
---|---|
protected scala.collection.mutable.HashMap<JobID,scala.Tuple2<ExecutionGraph,JobInfo>> |
JobManager.currentJobs()
Either running or not yet archived jobs (session hasn't been ended).
|
Constructor and Description |
---|
SubmittedJobGraph(JobGraph jobGraph,
JobInfo jobInfo)
Creates a
SubmittedJobGraph . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.