org.apache.lens.server.stats.store.log

Class LogStatisticsStore

java.lang.Object

org.apache.lens.server.api.events.AsyncEventListener<T>

org.apache.lens.server.stats.store.StatisticsStore<LoggableLensStatistics>

org.apache.lens.server.stats.store.log.LogStatisticsStore

All Implemented Interfaces:

LensEventListener<LoggableLensStatistics>

public class LogStatisticsStore
extends StatisticsStore<LoggableLensStatistics>

The Class LogStatisticsStore.

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOG_STORE_ERRORS The Constant LOG_STORE_ERRORS.

Fields inherited from interface org.apache.lens.server.api.events.LensEventListener

HANDLER_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
LogStatisticsStore() Instantiates a new log statistics store.

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize(org.apache.hadoop.hive.conf.HiveConf conf) Initialize the store.
void	process(LoggableLensStatistics event) Should implement the actual event handling.
void	start(LensEventService service) Start the Store.
void	stop(LensEventService service) Stop the store.

Methods inherited from class org.apache.lens.server.api.events.AsyncEventListener

getEventQueue, onEvent, stop

Methods inherited from class java.lang.Object

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

Field Detail

LOG_STORE_ERRORS

public static final String LOG_STORE_ERRORS

The Constant LOG_STORE_ERRORS.

See Also:

Constant Field Values

Constructor Detail

LogStatisticsStore

public LogStatisticsStore()

Instantiates a new log statistics store.

Method Detail

initialize

public void initialize(org.apache.hadoop.hive.conf.HiveConf conf)

Description copied from class: StatisticsStore

Initialize the store.

Specified by:

initialize in class StatisticsStore<LoggableLensStatistics>

Parameters:

conf - configuration for the store

process

public void process(LoggableLensStatistics event)

Description copied from class: AsyncEventListener

Should implement the actual event handling.

Specified by:

process in class AsyncEventListener<LoggableLensStatistics>

Parameters:

event - the event

start

public void start(LensEventService service)

Description copied from class: StatisticsStore

Start the Store.

Overrides:

start in class StatisticsStore<LoggableLensStatistics>

Parameters:

service - the service

stop

public void stop(LensEventService service)

Description copied from class: StatisticsStore

Stop the store.

Overrides:

stop in class StatisticsStore<LoggableLensStatistics>

Parameters:

service - the service