org.apache.spark.scheduler

Class ShuffleMapTask

Object

org.apache.spark.scheduler.Task<MapStatus>

org.apache.spark.scheduler.ShuffleMapTask

All Implemented Interfaces:

java.io.Serializable, Logging

public class ShuffleMapTask
extends Task<MapStatus>
implements Logging

A ShuffleMapTask divides the elements of an RDD into multiple buckets (based on a partitioner specified in the ShuffleDependency).

See Task for more information.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ShuffleMapTask(int partitionId) A constructor used only in test suites.
ShuffleMapTask(int stageId, Broadcast<byte[]> taskBinary, Partition partition, scala.collection.Seq<TaskLocation> locs)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Seq<TaskLocation>	preferredLocations()
MapStatus	runTask(TaskContext context)
String	toString()

Methods inherited from class org.apache.spark.scheduler.Task

deserializeWithDependencies, epoch, kill, killed, metrics, partitionId, run, serializeWithDependencies, stageId

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, 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

Constructor Detail

ShuffleMapTask

public ShuffleMapTask(int stageId,
              Broadcast<byte[]> taskBinary,
              Partition partition,
              scala.collection.Seq<TaskLocation> locs)

ShuffleMapTask

public ShuffleMapTask(int partitionId)

A constructor used only in test suites. This does not require passing in an RDD.

Method Detail

runTask

public MapStatus runTask(TaskContext context)

Specified by:

runTask in class Task<MapStatus>

preferredLocations

public scala.collection.Seq<TaskLocation> preferredLocations()

Overrides:

preferredLocations in class Task<MapStatus>

toString

public String toString()

Overrides:

toString in class Object