org.apache.spark.scheduler

Class TaskResultGetter

Object

org.apache.spark.scheduler.TaskResultGetter

All Implemented Interfaces:

Logging

public class TaskResultGetter
extends Object
implements Logging

Runs a thread pool that deserializes and remotely fetches (if necessary) task results.

Constructor Summary

Constructors

Constructor and Description
TaskResultGetter(SparkEnv sparkEnv, TaskSchedulerImpl scheduler)

Method Summary

Methods

Modifier and Type	Method and Description
void	enqueueFailedTask(TaskSetManager taskSetManager, long tid, scala.Enumeration.Value taskState, java.nio.ByteBuffer serializedData)
void	enqueueSuccessfulTask(TaskSetManager taskSetManager, long tid, java.nio.ByteBuffer serializedData)
void	stop()

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

Constructor Detail

TaskResultGetter

public TaskResultGetter(SparkEnv sparkEnv,
                TaskSchedulerImpl scheduler)

Method Detail

enqueueSuccessfulTask

public void enqueueSuccessfulTask(TaskSetManager taskSetManager,
                         long tid,
                         java.nio.ByteBuffer serializedData)

enqueueFailedTask

public void enqueueFailedTask(TaskSetManager taskSetManager,
                     long tid,
                     scala.Enumeration.Value taskState,
                     java.nio.ByteBuffer serializedData)

stop

public void stop()