public class SparkListenerTaskEnd extends java.lang.Object implements SparkListenerEvent, scala.Product, scala.Serializable
Constructor and Description |
---|
SparkListenerTaskEnd(int stageId,
int stageAttemptId,
java.lang.String taskType,
TaskEndReason reason,
TaskInfo taskInfo,
org.apache.spark.executor.TaskMetrics taskMetrics) |
Modifier and Type | Method and Description |
---|---|
TaskEndReason |
reason() |
int |
stageAttemptId() |
int |
stageId() |
TaskInfo |
taskInfo() |
org.apache.spark.executor.TaskMetrics |
taskMetrics() |
java.lang.String |
taskType() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SparkListenerTaskEnd(int stageId, int stageAttemptId, java.lang.String taskType, TaskEndReason reason, TaskInfo taskInfo, org.apache.spark.executor.TaskMetrics taskMetrics)
public int stageId()
public int stageAttemptId()
public java.lang.String taskType()
public TaskEndReason reason()
public TaskInfo taskInfo()
public org.apache.spark.executor.TaskMetrics taskMetrics()