org.apache.hadoop.yarn.logaggregation

クラス AggregatedLogFormat.LogReader

java.lang.Object

org.apache.hadoop.yarn.logaggregation.AggregatedLogFormat.LogReader

含まれているクラス:

AggregatedLogFormat

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public static class AggregatedLogFormat.LogReader
extends Object

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
LogReader(Configuration conf, Path remoteAppLogFile)

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close()
Map<ApplicationAccessType,String>	getApplicationAcls() Returns ACLs for the application.
String	getApplicationOwner() Returns the owner of the application.
DataInputStream	next(AggregatedLogFormat.LogKey key) Read the next key and return the value-stream.
static void	readAcontainerLogs(DataInputStream valueStream, Writer writer) Writes all logs for a single container to the provided writer.
static void	readAcontainerLogs(DataInputStream valueStream, Writer writer, long logUploadedTime) Writes all logs for a single container to the provided writer.
static void	readAContainerLogsForALogType(DataInputStream valueStream, PrintStream out) Keep calling this till you get a EOFException for getting logs of all types for a single container.
static void	readAContainerLogsForALogType(DataInputStream valueStream, PrintStream out, long logUploadedTime) Keep calling this till you get a EOFException for getting logs of all types for a single container.
static void	readAContainerLogsForALogType(DataInputStream valueStream, PrintStream out, long logUploadedTime, long bytes) Keep calling this till you get a EOFException for getting logs of all types for a single container for the specific bytes.
static int	readContainerLogsForALogType(DataInputStream valueStream, PrintStream out, long logUploadedTime, List<String> logType) Keep calling this till you get a EOFException for getting logs of the specific types for a single container.
static int	readContainerLogsForALogType(DataInputStream valueStream, PrintStream out, long logUploadedTime, List<String> logType, long bytes) Keep calling this till you get a EOFException for getting logs of the specific types for a single container.

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

LogReader

public LogReader(Configuration conf,
                 Path remoteAppLogFile)
          throws IOException

例外:

IOException

メソッドの詳細

getApplicationOwner

public String getApplicationOwner()
                           throws IOException

Returns the owner of the application.

戻り値:

the application owner.

例外:

IOException

getApplicationAcls

public Map<ApplicationAccessType,String> getApplicationAcls()
                                                     throws IOException

Returns ACLs for the application. An empty map is returned if no ACLs are found.

戻り値:

a map of the Application ACLs.

例外:

IOException

next

public DataInputStream next(AggregatedLogFormat.LogKey key)
                     throws IOException

Read the next key and return the value-stream.

パラメータ:

key -

戻り値:

the valueStream if there are more keys or null otherwise.

例外:

IOException

readAcontainerLogs

public static void readAcontainerLogs(DataInputStream valueStream,
                                      Writer writer,
                                      long logUploadedTime)
                               throws IOException

Writes all logs for a single container to the provided writer.

パラメータ:

valueStream -

writer -

logUploadedTime -

例外:

IOException

readAcontainerLogs

public static void readAcontainerLogs(DataInputStream valueStream,
                                      Writer writer)
                               throws IOException

Writes all logs for a single container to the provided writer.

パラメータ:

valueStream -

writer -

例外:

IOException

readAContainerLogsForALogType

public static void readAContainerLogsForALogType(DataInputStream valueStream,
                                                 PrintStream out,
                                                 long logUploadedTime)
                                          throws IOException

Keep calling this till you get a EOFException for getting logs of all types for a single container.

パラメータ:

valueStream -

out -

logUploadedTime -

例外:

IOException

readAContainerLogsForALogType

public static void readAContainerLogsForALogType(DataInputStream valueStream,
                                                 PrintStream out,
                                                 long logUploadedTime,
                                                 long bytes)
                                          throws IOException

Keep calling this till you get a EOFException for getting logs of all types for a single container for the specific bytes.

パラメータ:

valueStream -

out -

logUploadedTime -

bytes -

例外:

IOException

readAContainerLogsForALogType

public static void readAContainerLogsForALogType(DataInputStream valueStream,
                                                 PrintStream out)
                                          throws IOException

Keep calling this till you get a EOFException for getting logs of all types for a single container.

パラメータ:

valueStream -

out -

例外:

IOException

readContainerLogsForALogType

public static int readContainerLogsForALogType(DataInputStream valueStream,
                                               PrintStream out,
                                               long logUploadedTime,
                                               List<String> logType)
                                        throws IOException

Keep calling this till you get a EOFException for getting logs of the specific types for a single container.

パラメータ:

valueStream -

out -

logUploadedTime -

logType -

例外:

IOException

readContainerLogsForALogType

public static int readContainerLogsForALogType(DataInputStream valueStream,
                                               PrintStream out,
                                               long logUploadedTime,
                                               List<String> logType,
                                               long bytes)
                                        throws IOException

Keep calling this till you get a EOFException for getting logs of the specific types for a single container.

パラメータ:

valueStream -

out -

logUploadedTime -

logType -

例外:

IOException

close

public void close()