public class StageInfo
extends Object
Constructor and Description |
---|
StageInfo(int stageId,
int attemptId,
String name,
int numTasks,
scala.collection.Seq<RDDInfo> rddInfos,
scala.collection.Seq<Object> parentIds,
String details) |
Modifier and Type | Method and Description |
---|---|
scala.collection.mutable.HashMap<Object,AccumulableInfo> |
accumulables()
Terminal values of accumulables updated during this stage.
|
int |
attemptId() |
scala.Option<Object> |
completionTime()
Time when all tasks in the stage completed or when the stage was cancelled.
|
String |
details() |
scala.Option<String> |
failureReason()
If the stage failed, the reason why.
|
static StageInfo |
fromStage(org.apache.spark.scheduler.Stage stage,
scala.Option<Object> numTasks)
Construct a StageInfo from a Stage.
|
String |
name() |
int |
numTasks() |
scala.collection.Seq<Object> |
parentIds() |
scala.collection.Seq<RDDInfo> |
rddInfos() |
void |
stageFailed(String reason) |
int |
stageId() |
scala.Option<Object> |
submissionTime()
When this stage was submitted from the DAGScheduler to a TaskScheduler.
|
public StageInfo(int stageId, int attemptId, String name, int numTasks, scala.collection.Seq<RDDInfo> rddInfos, scala.collection.Seq<Object> parentIds, String details)
public static StageInfo fromStage(org.apache.spark.scheduler.Stage stage, scala.Option<Object> numTasks)
Each Stage is associated with one or many RDDs, with the boundary of a Stage marked by shuffle dependencies. Therefore, all ancestor RDDs related to this Stage's RDD through a sequence of narrow dependencies should also be associated with this Stage.
stage
- (undocumented)numTasks
- (undocumented)public int stageId()
public int attemptId()
public String name()
public int numTasks()
public scala.collection.Seq<RDDInfo> rddInfos()
public scala.collection.Seq<Object> parentIds()
public String details()
public scala.Option<Object> submissionTime()
public scala.Option<Object> completionTime()
public scala.Option<String> failureReason()
public scala.collection.mutable.HashMap<Object,AccumulableInfo> accumulables()
public void stageFailed(String reason)