public class ResultTask<T,U> extends Task<U> implements java.io.Serializable
See Task
for more information.
Constructor and Description |
---|
ResultTask(int stageId,
Broadcast<byte[]> taskBinary,
Partition partition,
scala.collection.Seq<TaskLocation> locs,
int outputId) |
Modifier and Type | Method and Description |
---|---|
int |
outputId() |
scala.collection.Seq<TaskLocation> |
preferredLocations() |
U |
runTask(TaskContext context) |
String |
toString() |
deserializeWithDependencies, epoch, kill, killed, metrics, partitionId, run, serializeWithDependencies, stageId
public ResultTask(int stageId, Broadcast<byte[]> taskBinary, Partition partition, scala.collection.Seq<TaskLocation> locs, int outputId)
public int outputId()
public U runTask(TaskContext context)
public scala.collection.Seq<TaskLocation> preferredLocations()
preferredLocations
in class Task<U>
public String toString()
toString
in class Object