Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
构造器和说明 |
---|
UserLogCleaner(UserLogManager userLogManager,
Configuration conf) |
限定符和类型 | 方法和说明 |
---|---|
void |
addOldUserLogsForDeletion(File loc,
Configuration conf)
Adds the job log directories for deletion with default retain hours.
|
void |
clearOldUserLogs(Configuration conf)
Clears all the logs in userlogs directory.
|
void |
deleteJobLogs(JobID jobid) |
void |
markJobLogsForDeletion(long jobCompletionTime,
int retainHours,
JobID jobid)
Adds job user-log directory to cleanup thread to delete logs after user-log
retain hours.
|
void |
run() |
void |
unmarkJobFromLogDeletion(JobID jobid)
Remove job from user log deletion.
|
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 UserLogCleaner(UserLogManager userLogManager, Configuration conf) throws IOException
IOException
public void deleteJobLogs(JobID jobid) throws IOException
IOException
public void addOldUserLogsForDeletion(File loc, Configuration conf) throws IOException
loc
- location of log directoryconf
- IOException
public void clearOldUserLogs(Configuration conf) throws IOException
conf
- IOException
public void markJobLogsForDeletion(long jobCompletionTime, int retainHours, JobID jobid)
jobCompletionTime
- job completion time in millisretainHours
- the user-log retain hours for the jobjobid
- JobID for which user logs should be deletedpublic void unmarkJobFromLogDeletion(JobID jobid)
jobid
- Copyright © 2009 The Apache Software Foundation