public class ContainerLogsUtils extends Object
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
ContainerLogsUtils() |
Modifier and Type | Method and Description |
---|---|
static List<File> |
getContainerLogDirs(org.apache.hadoop.yarn.api.records.ContainerId containerId,
String remoteUser,
Context context)
Finds the local directories that logs for the given container are stored
on.
|
static File |
getContainerLogFile(org.apache.hadoop.yarn.api.records.ContainerId containerId,
String fileName,
String remoteUser,
Context context)
Finds the log file with the given filename for the given container.
|
static FileInputStream |
openLogFileForRead(String containerIdStr,
File logFile,
Context context) |
public static List<File> getContainerLogDirs(org.apache.hadoop.yarn.api.records.ContainerId containerId, String remoteUser, Context context) throws org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.yarn.exceptions.YarnException
public static File getContainerLogFile(org.apache.hadoop.yarn.api.records.ContainerId containerId, String fileName, String remoteUser, Context context) throws org.apache.hadoop.yarn.exceptions.YarnException
org.apache.hadoop.yarn.exceptions.YarnException
public static FileInputStream openLogFileForRead(String containerIdStr, File logFile, Context context) throws IOException
IOException
Copyright © 2018 Apache Software Foundation. All Rights Reserved.