org.apache.hadoop.yarn.logaggregation

Class AggregatedLogFormat.LogWriter

java.lang.Object

org.apache.hadoop.yarn.logaggregation.AggregatedLogFormat.LogWriter

Enclosing class:

AggregatedLogFormat

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

The writer that writes out the aggregated logs.

Constructor Summary

Constructors

Constructor and Description
AggregatedLogFormat.LogWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path remoteAppLogFile, org.apache.hadoop.security.UserGroupInformation userUgi)

Method Summary

Methods

Modifier and Type	Method and Description
void	append(AggregatedLogFormat.LogKey logKey, AggregatedLogFormat.LogValue logValue)
void	close()
org.apache.hadoop.io.file.tfile.TFile.Writer	getWriter()
void	writeApplicationACLs(Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls)
void	writeApplicationOwner(String user)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatedLogFormat.LogWriter

public AggregatedLogFormat.LogWriter(org.apache.hadoop.conf.Configuration conf,
                             org.apache.hadoop.fs.Path remoteAppLogFile,
                             org.apache.hadoop.security.UserGroupInformation userUgi)
                              throws IOException

Throws:

IOException

Method Detail

getWriter

public org.apache.hadoop.io.file.tfile.TFile.Writer getWriter()

writeApplicationOwner

public void writeApplicationOwner(String user)
                           throws IOException

Throws:

IOException

writeApplicationACLs

public void writeApplicationACLs(Map<org.apache.hadoop.yarn.api.records.ApplicationAccessType,String> appAcls)
                          throws IOException

Throws:

IOException

append

public void append(AggregatedLogFormat.LogKey logKey,
          AggregatedLogFormat.LogValue logValue)
            throws IOException

Throws:

IOException

close

public void close()