@InterfaceAudience.Private public static class AggregatedLogFormat.LogValue extends Object
Constructor and Description |
---|
AggregatedLogFormat.LogValue(List<String> rootLogDirs,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String user) |
AggregatedLogFormat.LogValue(List<String> rootLogDirs,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
String user,
org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext,
Set<String> alreadyUploadedLogFiles,
boolean appFinished,
boolean containerFinished) |
Modifier and Type | Method and Description |
---|---|
Set<String> |
getAllExistingFilesMeta() |
Set<String> |
getCurrentUpLoadedFileMeta() |
Set<org.apache.hadoop.fs.Path> |
getCurrentUpLoadedFilesPath() |
String |
getUser() |
FileInputStream |
secureOpenFile(File logFile) |
void |
write(DataOutputStream out,
Set<File> pendingUploadFiles) |
public AggregatedLogFormat.LogValue(List<String> rootLogDirs, org.apache.hadoop.yarn.api.records.ContainerId containerId, String user)
public AggregatedLogFormat.LogValue(List<String> rootLogDirs, org.apache.hadoop.yarn.api.records.ContainerId containerId, String user, org.apache.hadoop.yarn.api.records.LogAggregationContext logAggregationContext, Set<String> alreadyUploadedLogFiles, boolean appFinished, boolean containerFinished)
public void write(DataOutputStream out, Set<File> pendingUploadFiles) throws IOException
IOException
public FileInputStream secureOpenFile(File logFile) throws IOException
IOException
public String getUser()
public Set<org.apache.hadoop.fs.Path> getCurrentUpLoadedFilesPath()
Copyright © 2018 Apache Software Foundation. All Rights Reserved.