org.apache.hadoop.mapred

Class ReduceTask.ReduceCopier.MapOutputCopier

java.lang.Object

java.lang.Thread

org.apache.hadoop.mapred.ReduceTask.ReduceCopier.MapOutputCopier

All Implemented Interfaces:

Runnable

Enclosing class:

ReduceTask.ReduceCopier<K,V>

public class ReduceTask.ReduceCopier.MapOutputCopier
extends Thread

Copies map outputs as they become available

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ReduceTask.ReduceCopier.MapOutputCopier(JobConf job, Reporter reporter, SecretKey jobTokenSecret)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	fail() Fail the current file that we are fetching
ReduceTask.ReduceCopier.MapOutputLocation	getLocation() Get the current map output location.
protected HttpURLConnection	openConnection(URL url)
void	run() Loop forever and fetch map outputs as they become available.
InputStream	setupSecureConnection(ReduceTask.ReduceCopier.MapOutputLocation mapOutputLoc, URLConnection connection)

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReduceTask.ReduceCopier.MapOutputCopier

public ReduceTask.ReduceCopier.MapOutputCopier(JobConf job,
                                       Reporter reporter,
                                       SecretKey jobTokenSecret)

Method Detail

fail

public boolean fail()

Fail the current file that we are fetching

Returns:

were we currently fetching?

getLocation

public ReduceTask.ReduceCopier.MapOutputLocation getLocation()

Get the current map output location.

run

public void run()

Loop forever and fetch map outputs as they become available. The thread exits when it is interrupted by ReduceTaskRunner

Specified by:

run in interface Runnable

Overrides:

run in class Thread

openConnection

protected HttpURLConnection openConnection(URL url)
                                    throws IOException

Throws:

IOException

setupSecureConnection

public InputStream setupSecureConnection(ReduceTask.ReduceCopier.MapOutputLocation mapOutputLoc,
                                URLConnection connection)
                                  throws IOException

Throws:

IOException