This project has retired. For details please refer to its Attic page.

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

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

StatisticsLogPartitionHandler()

Method Summary

void	initialize(org.apache.hadoop.conf.Configuration 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.conf.Configuration 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