public class ShuffleMapTask extends Task<MapStatus> implements Logging
See Task
for more information.
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) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<TaskLocation> |
preferredLocations() |
MapStatus |
runTask(TaskContext context) |
String |
toString() |
deserializeWithDependencies, epoch, kill, killed, metrics, partitionId, run, serializeWithDependencies, stageId
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public ShuffleMapTask(int stageId, Broadcast<byte[]> taskBinary, Partition partition, scala.collection.Seq<TaskLocation> locs)
public ShuffleMapTask(int partitionId)
public MapStatus runTask(TaskContext context)
public scala.collection.Seq<TaskLocation> preferredLocations()
preferredLocations
in class Task<MapStatus>
public String toString()
toString
in class Object