protected static class HDFSOutputConnector.CreateFileThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected Throwable |
exception |
protected InputStream |
input |
protected org.apache.hadoop.fs.Path |
path |
protected HDFSSession |
session |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
HDFSOutputConnector.CreateFileThread(HDFSSession session,
org.apache.hadoop.fs.Path path,
InputStream input) |
Modifier and Type | Method and Description |
---|---|
void |
finishUp() |
void |
run() |
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
protected final HDFSSession session
protected final org.apache.hadoop.fs.Path path
protected final InputStream input
protected Throwable exception
public HDFSOutputConnector.CreateFileThread(HDFSSession session, org.apache.hadoop.fs.Path path, InputStream input)
public void finishUp() throws InterruptedException, IOException
InterruptedException
IOException