Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
DirectShuffleEventFetcher(org.apache.hadoop.mapreduce.TaskAttemptID reduce,
org.apache.hadoop.mapred.TaskUmbilicalProtocol umbilical,
org.apache.hadoop.mapreduce.task.reduce.ShuffleScheduler<K,V> scheduler,
org.apache.hadoop.mapreduce.task.reduce.ExceptionReporter reporter,
int maxEventsToFetch) |
Modifier and Type | Method and Description |
---|---|
protected int |
getMapCompletionEvents()
Queries the
TaskTracker for a set of map-completion events
from a given event ID. |
void |
run() |
void |
shutDown() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public DirectShuffleEventFetcher(org.apache.hadoop.mapreduce.TaskAttemptID reduce, org.apache.hadoop.mapred.TaskUmbilicalProtocol umbilical, org.apache.hadoop.mapreduce.task.reduce.ShuffleScheduler<K,V> scheduler, org.apache.hadoop.mapreduce.task.reduce.ExceptionReporter reporter, int maxEventsToFetch)
public void shutDown()
protected int getMapCompletionEvents() throws IOException, InterruptedException
TaskTracker
for a set of map-completion events
from a given event ID.IOException
InterruptedException
Copyright © 2019 Apache Software Foundation. All Rights Reserved.