org.apache.hadoop.yarn.logaggregation

Class LogCLIHelpers

java.lang.Object

org.apache.hadoop.yarn.logaggregation.LogCLIHelpers

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class LogCLIHelpers
extends Object
implements org.apache.hadoop.conf.Configurable

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONTAINER_ON_NODE_PATTERN
static String	PER_LOG_FILE_INFO_PATTERN

Constructor Summary

Constructors

Constructor and Description
LogCLIHelpers()

Method Summary

Modifier and Type	Method and Description
void	closePrintStream(PrintStream out)
int	dumpAContainerLogsForLogType(ContainerLogsRequest options)
int	dumpAContainerLogsForLogType(ContainerLogsRequest options, boolean outputFailure)
int	dumpAContainerLogsForLogTypeWithoutNodeId(ContainerLogsRequest options)
int	dumpAContainersLogs(String appId, String containerId, String nodeId, String jobOwner)
int	dumpAllContainersLogs(ContainerLogsRequest options)
org.apache.hadoop.conf.Configuration	getConf()
static String	getOwnerForAppIdOrNull(org.apache.hadoop.yarn.api.records.ApplicationId appId, String bestGuess, org.apache.hadoop.conf.Configuration conf)
static String	guessOwnerWithFileFormat(LogAggregationFileController fileFormat, org.apache.hadoop.yarn.api.records.ApplicationId appId, String bestGuess, org.apache.hadoop.conf.Configuration conf)
Set<ContainerLogFileInfo>	listContainerLogs(ContainerLogsRequest options)
int	printAContainerLogMetadata(ContainerLogsRequest options, PrintStream out, PrintStream err)
void	printContainersList(ContainerLogsRequest options, PrintStream out, PrintStream err)
void	printNodesList(ContainerLogsRequest options, PrintStream out, PrintStream err)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

PER_LOG_FILE_INFO_PATTERN

public static final String PER_LOG_FILE_INFO_PATTERN

CONTAINER_ON_NODE_PATTERN

public static final String CONTAINER_ON_NODE_PATTERN

See Also:

Constant Field Values

Constructor Detail

LogCLIHelpers

public LogCLIHelpers()

Method Detail

dumpAContainersLogs

@InterfaceAudience.Private
 @VisibleForTesting
public int dumpAContainersLogs(String appId,
                                                                              String containerId,
                                                                              String nodeId,
                                                                              String jobOwner)
                                                                       throws IOException

Throws:

IOException

guessOwnerWithFileFormat

public static String guessOwnerWithFileFormat(LogAggregationFileController fileFormat,
                                              org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                              String bestGuess,
                                              org.apache.hadoop.conf.Configuration conf)
                                       throws IOException

Throws:

IOException

getOwnerForAppIdOrNull

@InterfaceAudience.Private
 @VisibleForTesting
public static String getOwnerForAppIdOrNull(org.apache.hadoop.yarn.api.records.ApplicationId appId,
                                                                                           String bestGuess,
                                                                                           org.apache.hadoop.conf.Configuration conf)

dumpAContainerLogsForLogType

@InterfaceAudience.Private
 @VisibleForTesting
public int dumpAContainerLogsForLogType(ContainerLogsRequest options)
                                                                                throws IOException

Throws:

IOException

dumpAContainerLogsForLogType

@InterfaceAudience.Private
 @VisibleForTesting
public int dumpAContainerLogsForLogType(ContainerLogsRequest options,
                                                                                       boolean outputFailure)
                                                                                throws IOException

Throws:

IOException

dumpAContainerLogsForLogTypeWithoutNodeId

@InterfaceAudience.Private
public int dumpAContainerLogsForLogTypeWithoutNodeId(ContainerLogsRequest options)
                                                                         throws IOException

Throws:

IOException

dumpAllContainersLogs

@InterfaceAudience.Private
public int dumpAllContainersLogs(ContainerLogsRequest options)
                                                     throws IOException

Throws:

IOException

printAContainerLogMetadata

@InterfaceAudience.Private
public int printAContainerLogMetadata(ContainerLogsRequest options,
                                                                 PrintStream out,
                                                                 PrintStream err)
                                                          throws IOException

Throws:

IOException

printNodesList

@InterfaceAudience.Private
public void printNodesList(ContainerLogsRequest options,
                                                      PrintStream out,
                                                      PrintStream err)
                                               throws IOException

Throws:

IOException

printContainersList

@InterfaceAudience.Private
public void printContainersList(ContainerLogsRequest options,
                                                           PrintStream out,
                                                           PrintStream err)
                                                    throws IOException

Throws:

IOException

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

closePrintStream

public void closePrintStream(PrintStream out)

listContainerLogs

@InterfaceAudience.Private
public Set<ContainerLogFileInfo> listContainerLogs(ContainerLogsRequest options)
                                                                       throws IOException

Throws:

IOException