public class SparkListenerTaskEnd extends Object implements SparkListenerEvent, scala.Product, scala.Serializable
Constructor and Description |
---|
SparkListenerTaskEnd(int stageId,
int stageAttemptId,
String taskType,
TaskEndReason reason,
TaskInfo taskInfo,
org.apache.spark.executor.TaskMetrics taskMetrics) |
Modifier and Type | Method and Description |
---|---|
abstract static boolean |
canEqual(Object that) |
abstract static boolean |
equals(Object that) |
abstract static int |
productArity() |
abstract static Object |
productElement(int n) |
static scala.collection.Iterator<Object> |
productIterator() |
static String |
productPrefix() |
TaskEndReason |
reason() |
int |
stageAttemptId() |
int |
stageId() |
TaskInfo |
taskInfo() |
org.apache.spark.executor.TaskMetrics |
taskMetrics() |
String |
taskType() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
logEvent
public SparkListenerTaskEnd(int stageId, int stageAttemptId, String taskType, TaskEndReason reason, TaskInfo taskInfo, org.apache.spark.executor.TaskMetrics taskMetrics)
public abstract static boolean canEqual(Object that)
public abstract static boolean equals(Object that)
public abstract static Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<Object> productIterator()
public static String productPrefix()
public int stageId()
public int stageAttemptId()
public String taskType()
public TaskEndReason reason()
public TaskInfo taskInfo()
public org.apache.spark.executor.TaskMetrics taskMetrics()