org.apache.spark.scheduler.cluster

Class CoarseGrainedClusterMessages.StatusUpdate

Object

org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.StatusUpdate

All Implemented Interfaces:

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

Enclosing class:

CoarseGrainedClusterMessages

public static class CoarseGrainedClusterMessages.StatusUpdate
extends Object
implements CoarseGrainedClusterMessage, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StatusUpdate(String executorId, long taskId, scala.Enumeration.Value state, org.apache.spark.util.SerializableBuffer data, int taskCpus, scala.collection.immutable.Map<String,ResourceInformation> resources)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.util.SerializableBuffer	data()
String	executorId()
scala.collection.immutable.Map<String,ResourceInformation>	resources()
scala.Enumeration.Value	state()
int	taskCpus()
long	taskId()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

StatusUpdate

public StatusUpdate(String executorId,
                    long taskId,
                    scala.Enumeration.Value state,
                    org.apache.spark.util.SerializableBuffer data,
                    int taskCpus,
                    scala.collection.immutable.Map<String,ResourceInformation> resources)

Method Detail

executorId

public String executorId()

taskId

public long taskId()

state

public scala.Enumeration.Value state()

data

public org.apache.spark.util.SerializableBuffer data()

taskCpus

public int taskCpus()

resources

public scala.collection.immutable.Map<String,ResourceInformation> resources()