public class ReduceTask.ReduceCopier.MapOutputCopier
extends java.lang.Thread
Constructor and Description |
---|
ReduceTask.ReduceCopier.MapOutputCopier(JobConf job,
Reporter reporter,
javax.crypto.SecretKey jobTokenSecret) |
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 java.net.HttpURLConnection |
openConnection(java.net.URL url) |
void |
run()
Loop forever and fetch map outputs as they become available.
|
java.io.InputStream |
setupSecureConnection(ReduceTask.ReduceCopier.MapOutputLocation mapOutputLoc,
java.net.URLConnection connection) |
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 boolean fail()
public ReduceTask.ReduceCopier.MapOutputLocation getLocation()
public void run()
ReduceTaskRunner
run
in interface java.lang.Runnable
run
in class java.lang.Thread
protected java.net.HttpURLConnection openConnection(java.net.URL url) throws java.io.IOException
java.io.IOException
public java.io.InputStream setupSecureConnection(ReduceTask.ReduceCopier.MapOutputLocation mapOutputLoc, java.net.URLConnection connection) throws java.io.IOException
java.io.IOException
Copyright © 2009 The Apache Software Foundation