org.apache.spark.scheduler

Class CompletionEvent

Object

org.apache.spark.scheduler.CompletionEvent

All Implemented Interfaces:

java.io.Serializable, DAGSchedulerEvent, scala.Equals, scala.Product

public class CompletionEvent
extends Object
implements DAGSchedulerEvent, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompletionEvent(Task<?> task, TaskEndReason reason, Object result, scala.collection.mutable.Map<Object,Object> accumUpdates, TaskInfo taskInfo, org.apache.spark.executor.TaskMetrics taskMetrics)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.mutable.Map<Object,Object>	accumUpdates()
TaskEndReason	reason()
Object	result()
Object	task()
TaskInfo	taskInfo()
org.apache.spark.executor.TaskMetrics	taskMetrics()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

CompletionEvent

public CompletionEvent(Task<?> task,
               TaskEndReason reason,
               Object result,
               scala.collection.mutable.Map<Object,Object> accumUpdates,
               TaskInfo taskInfo,
               org.apache.spark.executor.TaskMetrics taskMetrics)

Method Detail

task

public Object task()

reason

public TaskEndReason reason()

result

public Object result()

accumUpdates

public scala.collection.mutable.Map<Object,Object> accumUpdates()

taskInfo

public TaskInfo taskInfo()

taskMetrics

public org.apache.spark.executor.TaskMetrics taskMetrics()