Package org.apache.hadoop.hbase.coprocessor.example.row.stats.ringbuffer

Class RowStatisticsEventHandler

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.row.stats.ringbuffer.RowStatisticsEventHandler

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<RowStatisticsRingBufferEnvelope>

@Private
public class RowStatisticsEventHandler
extends Object
implements com.lmax.disruptor.EventHandler<RowStatisticsRingBufferEnvelope>

Field Summary

Fields

Modifier and Type	Field	Description
private final BufferedMutator	bufferedMutator
private static final org.slf4j.Logger	LOG
private final Counter	rowStatisticsPutFailures

Constructor Summary

Constructors

Constructor	Description
RowStatisticsEventHandler(BufferedMutator bufferedMutator, Counter rowStatisticsPutFailures)

Method Summary

Modifier and Type	Method	Description
void	onEvent(RowStatisticsRingBufferEnvelope event, long sequence, boolean endOfBatch)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

bufferedMutator

private final BufferedMutator bufferedMutator

rowStatisticsPutFailures

private final Counter rowStatisticsPutFailures

Constructor Details

RowStatisticsEventHandler

public RowStatisticsEventHandler(BufferedMutator bufferedMutator,
 Counter rowStatisticsPutFailures)

Method Details

onEvent

public void onEvent(RowStatisticsRingBufferEnvelope event,
 long sequence,
 boolean endOfBatch)
             throws Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<RowStatisticsRingBufferEnvelope>

Throws:

Exception