alluxio.logserver

Class AlluxioLogServerProcess

java.lang.Object

alluxio.logserver.AlluxioLogServerProcess

All Implemented Interfaces:

Process

public class AlluxioLogServerProcess
extends java.lang.Object
implements Process

A centralized log server for Alluxio. Alluxio masters and workers generate logs and store the logs in local storage. AlluxioLogServerProcess allows masters and workers to "push" their logs to a centralized log server where another copy of the logs will be stored.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LOGSERVER_CLIENT_LOGGER_APPENDER_NAME Name of the appender used by log server to perform actual logging of messages received from remote Alluxio servers.

Constructor Summary

Constructors

Constructor and Description
AlluxioLogServerProcess(java.lang.String baseLogsDir) Constructs an AlluxioLogServerProcess instance.

Method Summary

Modifier and Type	Method and Description
void	start() Creates and starts logging server and client thread pool.
void	stop() Stops the main thread of AlluxioLogServerProcess.
boolean	waitForReady(int timeoutMs)

Methods inherited from class java.lang.Object

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

Field Detail

LOGSERVER_CLIENT_LOGGER_APPENDER_NAME

public static final java.lang.String LOGSERVER_CLIENT_LOGGER_APPENDER_NAME

Name of the appender used by log server to perform actual logging of messages received from remote Alluxio servers. It has to match the value in log4j.properties.

See Also:

Constant Field Values

Constructor Detail

AlluxioLogServerProcess

public AlluxioLogServerProcess(java.lang.String baseLogsDir)

Constructs an AlluxioLogServerProcess instance.

Parameters:

baseLogsDir - base directory to store the logs pushed from remote Alluxio servers

Method Detail

start

public void start()
           throws java.lang.Exception

Creates and starts logging server and client thread pool.

Specified by:

start in interface Process

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Stops the main thread of AlluxioLogServerProcess. Close the server socket, shutdown the thread pool, stop accepting new requests, and blocks until all worker threads terminate.

Specified by:

stop in interface Process

Throws:

java.lang.Exception

waitForReady

public boolean waitForReady(int timeoutMs)

Specified by:

waitForReady in interface Process