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

Class StatisticsLogPartitionHandler

java.lang.Object

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

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

All Implemented Interfaces:

LensEventListener<PartitionEvent>

public class StatisticsLogPartitionHandler
extends AsyncEventListener<PartitionEvent>

Class used to copy log files to HDFS and add partition to hive metastore.

Field Summary

Fields

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

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

HANDLER_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
StatisticsLogPartitionHandler()

Method Summary

Modifier and Type	Method and Description
void	initialize(org.apache.hadoop.hive.conf.HiveConf conf) Initialize.
void	process(PartitionEvent event) Should implement the actual event handling.

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_PARTITION_HANDLER_COUNTER

public static final String LOG_PARTITION_HANDLER_COUNTER

The Constant LOG_PARTITION_HANDLER_COUNTER.

See Also:

Constant Field Values

Constructor Detail

StatisticsLogPartitionHandler

public StatisticsLogPartitionHandler()

Method Detail

initialize

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

Initialize.

Parameters:

conf - the conf

process

public void process(PartitionEvent event)

Description copied from class: AsyncEventListener

Should implement the actual event handling.

Specified by:

process in class AsyncEventListener<PartitionEvent>

Parameters:

event - the event