org.apache.spark.scheduler.cluster.mesos

Class MesosTaskLaunchData

Object

org.apache.spark.scheduler.cluster.mesos.MesosTaskLaunchData

All Implemented Interfaces:

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

public class MesosTaskLaunchData
extends Object
implements Logging, scala.Product, scala.Serializable

Wrapper for serializing the data sent when launching Mesos tasks.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MesosTaskLaunchData(java.nio.ByteBuffer serializedTask, int attemptNumber)

Method Summary

Methods

Modifier and Type	Method and Description
int	attemptNumber()
static MesosTaskLaunchData	fromByteString(org.apache.mesos.protobuf.ByteString byteString)
java.nio.ByteBuffer	serializedTask()
org.apache.mesos.protobuf.ByteString	toByteString()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

MesosTaskLaunchData

public MesosTaskLaunchData(java.nio.ByteBuffer serializedTask,
                   int attemptNumber)

Method Detail

fromByteString

public static MesosTaskLaunchData fromByteString(org.apache.mesos.protobuf.ByteString byteString)

serializedTask

public java.nio.ByteBuffer serializedTask()

attemptNumber

public int attemptNumber()

toByteString

public org.apache.mesos.protobuf.ByteString toByteString()