org.apache.hadoop.yarn.logaggregation

Class AggregatedLogFormat.LogValue

java.lang.Object

org.apache.hadoop.yarn.logaggregation.AggregatedLogFormat.LogValue

Enclosing class:

AggregatedLogFormat

@InterfaceAudience.Private
public static class AggregatedLogFormat.LogValue
extends Object

Constructor Summary

Constructors

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, AggregatedLogFormat.LogRetentionContext retentionContext, boolean appFinished, boolean containerFinished)

Method Summary

Methods

Modifier and Type	Method and Description
Set<String>	getAllExistingFilesMeta()
Set<String>	getCurrentUpLoadedFileMeta()
Set<org.apache.hadoop.fs.Path>	getCurrentUpLoadedFilesPath()
Set<org.apache.hadoop.fs.Path>	getObseleteRetentionLogFiles()
Set<File>	getPendingLogFilesToUploadForThisContainer()
String	getUser()
FileInputStream	secureOpenFile(File logFile)
void	write(DataOutputStream out, Set<File> pendingUploadFiles)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatedLogFormat.LogValue

public AggregatedLogFormat.LogValue(List<String> rootLogDirs,
                            org.apache.hadoop.yarn.api.records.ContainerId containerId,
                            String user)

AggregatedLogFormat.LogValue

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,
                            AggregatedLogFormat.LogRetentionContext retentionContext,
                            boolean appFinished,
                            boolean containerFinished)

Method Detail

getPendingLogFilesToUploadForThisContainer

public Set<File> getPendingLogFilesToUploadForThisContainer()

write

public void write(DataOutputStream out,
         Set<File> pendingUploadFiles)
           throws IOException

Throws:

IOException

secureOpenFile

public FileInputStream secureOpenFile(File logFile)
                               throws IOException

Throws:

IOException

getUser

public String getUser()

getCurrentUpLoadedFilesPath

public Set<org.apache.hadoop.fs.Path> getCurrentUpLoadedFilesPath()

getCurrentUpLoadedFileMeta

public Set<String> getCurrentUpLoadedFileMeta()

getObseleteRetentionLogFiles

public Set<org.apache.hadoop.fs.Path> getObseleteRetentionLogFiles()

getAllExistingFilesMeta

public Set<String> getAllExistingFilesMeta()