org.apache.hadoop.yarn.logaggregation

Class LogToolUtils

java.lang.Object

org.apache.hadoop.yarn.logaggregation.LogToolUtils

public final class LogToolUtils
extends Object

This class contains several utility function which could be used in different log tools.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONTAINER_ON_NODE_PATTERN

Method Summary

Modifier and Type	Method and Description
static PrintStream	createPrintStream(String localDir, String nodeId, String containerId) Create the container log file under given (local directory/nodeId) and return the PrintStream object.
static void	outputContainerLog(String containerId, String nodeId, String fileName, long fileLength, long outputSize, String lastModifiedTime, InputStream fis, OutputStream os, byte[] buf, ContainerLogAggregationType logType) Output container log.
static void	outputContainerLogThroughZeroCopy(String containerId, String nodeId, String fileName, long fileLength, long outputSize, String lastModifiedTime, FileInputStream fis, OutputStream os, ContainerLogAggregationType logType)

Methods inherited from class java.lang.Object

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

Field Detail

CONTAINER_ON_NODE_PATTERN

public static final String CONTAINER_ON_NODE_PATTERN

See Also:

Constant Field Values

Method Detail

outputContainerLog

public static void outputContainerLog(String containerId,
                                      String nodeId,
                                      String fileName,
                                      long fileLength,
                                      long outputSize,
                                      String lastModifiedTime,
                                      InputStream fis,
                                      OutputStream os,
                                      byte[] buf,
                                      ContainerLogAggregationType logType)
                               throws IOException

Output container log.

Parameters:

containerId - the containerId

nodeId - the nodeId

fileName - the log file name

fileLength - the log file length

outputSize - the output size

lastModifiedTime - the log file last modified time

fis - the log file input stream

os - the output stream

buf - the buffer

logType - the log type.

Throws:

IOException - if we can not access the log file.

outputContainerLogThroughZeroCopy

public static void outputContainerLogThroughZeroCopy(String containerId,
                                                     String nodeId,
                                                     String fileName,
                                                     long fileLength,
                                                     long outputSize,
                                                     String lastModifiedTime,
                                                     FileInputStream fis,
                                                     OutputStream os,
                                                     ContainerLogAggregationType logType)
                                              throws IOException

Throws:

IOException

createPrintStream

public static PrintStream createPrintStream(String localDir,
                                            String nodeId,
                                            String containerId)
                                     throws IOException

Create the container log file under given (local directory/nodeId) and return the PrintStream object.

Parameters:

localDir - the Local Dir

nodeId - the NodeId

containerId - the ContainerId

Returns:

the printStream object

Throws:

IOException - if an I/O error occurs