|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.TaskLog
public class TaskLog
A simple logger to handle the task-specific user logs.
This class uses the system property hadoop.log.dir
.
Nested Class Summary | |
---|---|
static class |
TaskLog.LogName
The filter for userlogs. |
Constructor Summary | |
---|---|
TaskLog()
|
Method Summary | |
---|---|
static String |
addCommand(List<String> cmd,
boolean isExecutable)
Add quotes to each of the command strings and return as a single string |
static List<String> |
captureDebugOut(List<String> cmd,
File debugoutFilename)
Wrap a command in a shell to capture debug script's stdout and stderr to debugout. |
static List<String> |
captureOutAndError(List<String> cmd,
File stdoutFilename,
File stderrFilename,
long tailLength)
Wrap a command in a shell to capture stdout and stderr to files. |
static List<String> |
captureOutAndError(List<String> setup,
List<String> cmd,
File stdoutFilename,
File stderrFilename,
long tailLength)
Wrap a command in a shell to capture stdout and stderr to files. |
static void |
cleanup(int logsRetainHours)
Purge old user logs. |
static File |
getTaskLogFile(String taskid,
TaskLog.LogName filter)
Deprecated. |
static File |
getTaskLogFile(TaskAttemptID taskid,
TaskLog.LogName filter)
|
static long |
getTaskLogLength(JobConf conf)
Get the desired maximum length of task's logs. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TaskLog()
Method Detail |
---|
@Deprecated public static File getTaskLogFile(String taskid, TaskLog.LogName filter)
public static File getTaskLogFile(TaskAttemptID taskid, TaskLog.LogName filter)
public static void cleanup(int logsRetainHours) throws IOException
IOException
public static long getTaskLogLength(JobConf conf)
conf
- the job to look in
public static List<String> captureOutAndError(List<String> cmd, File stdoutFilename, File stderrFilename, long tailLength) throws IOException
cmd
- The command and the arguments that should be runstdoutFilename
- The filename that stdout should be saved tostderrFilename
- The filename that stderr should be saved totailLength
- The length of the tail to be saved.
IOException
public static List<String> captureOutAndError(List<String> setup, List<String> cmd, File stdoutFilename, File stderrFilename, long tailLength) throws IOException
setup
- The setup commands for the execed process.cmd
- The command and the arguments that should be runstdoutFilename
- The filename that stdout should be saved tostderrFilename
- The filename that stderr should be saved totailLength
- The length of the tail to be saved.
IOException
public static String addCommand(List<String> cmd, boolean isExecutable) throws IOException
cmd
- The command to be quotedisExecutable
- makes shell path if the first
argument is executable
IOException
public static List<String> captureDebugOut(List<String> cmd, File debugoutFilename) throws IOException
cmd
- The command and the arguments that should be rundebugoutFilename
- The filename that stdout and stderr
should be saved to.
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |