org.apache.spark.scheduler

Class DirectTaskResult<T>

Object

org.apache.spark.scheduler.DirectTaskResult<T>

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, TaskResult<T>

public class DirectTaskResult<T>
extends Object
implements TaskResult<T>, java.io.Externalizable

A TaskResult that contains the task's return value and accumulator updates.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DirectTaskResult()
DirectTaskResult(java.nio.ByteBuffer valueBytes, scala.collection.mutable.Map<Object,Object> accumUpdates, org.apache.spark.executor.TaskMetrics metrics)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.mutable.Map<Object,Object>	accumUpdates()
org.apache.spark.executor.TaskMetrics	metrics()
void	readExternal(java.io.ObjectInput in)
T	value()
java.nio.ByteBuffer	valueBytes()
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class Object

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

Constructor Detail

DirectTaskResult

public DirectTaskResult(java.nio.ByteBuffer valueBytes,
                scala.collection.mutable.Map<Object,Object> accumUpdates,
                org.apache.spark.executor.TaskMetrics metrics)

DirectTaskResult

public DirectTaskResult()

Method Detail

valueBytes

public java.nio.ByteBuffer valueBytes()

accumUpdates

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

metrics

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

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Specified by:

writeExternal in interface java.io.Externalizable

readExternal

public void readExternal(java.io.ObjectInput in)

Specified by:

readExternal in interface java.io.Externalizable

value

public T value()