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

Class RowStatisticsTableRecorder

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.row.stats.recorder.RowStatisticsTableRecorder

All Implemented Interfaces:

RowStatisticsRecorder

@Private
public final class RowStatisticsTableRecorder
extends Object
implements RowStatisticsRecorder

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	RowStatisticsTableRecorder.TableRecorderExceptionListener

Field Summary

Fields

Modifier and Type	Field	Description
private final BufferedMutator	bufferedMutator
private final AtomicBoolean	closed
private static final int	DEFAULT_EVENT_COUNT
private final com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope>	disruptor
private static final long	DISRUPTOR_SHUTDOWN_TIMEOUT_MS
private static final org.slf4j.Logger	LOG
private final com.lmax.disruptor.RingBuffer<RowStatisticsRingBufferEnvelope>	ringBuffer
private final Counter	rowStatisticsDropped

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RowStatisticsTableRecorder(BufferedMutator bufferedMutator, com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope> disruptor, Counter rowStatisticsDropped)

Method Summary

Modifier and Type	Method	Description
void	close()
static RowStatisticsTableRecorder	forClusterConnection(Connection clusterConnection, Counter rowStatisticsDropped, Counter rowStatisticsPutFailed)
private static BufferedMutator	initializeBufferedMutator(Connection conn, Counter rowStatisticsPutFailed)
private static com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope>	initializeDisruptor(BufferedMutator bufferedMutator, Counter rowStatisticsPutFailures)
void	record(RowStatisticsImpl rowStatistics, Optional<byte[]> fullRegionName)

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

DEFAULT_EVENT_COUNT

private static final int DEFAULT_EVENT_COUNT

See Also:

• Constant Field Values

DISRUPTOR_SHUTDOWN_TIMEOUT_MS

private static final long DISRUPTOR_SHUTDOWN_TIMEOUT_MS

See Also:

• Constant Field Values

bufferedMutator

private final BufferedMutator bufferedMutator

rowStatisticsDropped

private final Counter rowStatisticsDropped

disruptor

private final com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope> disruptor

ringBuffer

private final com.lmax.disruptor.RingBuffer<RowStatisticsRingBufferEnvelope> ringBuffer

closed

private final AtomicBoolean closed

Constructor Details

RowStatisticsTableRecorder

private RowStatisticsTableRecorder(BufferedMutator bufferedMutator,
 com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope> disruptor,
 Counter rowStatisticsDropped)

Method Details

forClusterConnection

public static RowStatisticsTableRecorder forClusterConnection(Connection clusterConnection,
 Counter rowStatisticsDropped,
 Counter rowStatisticsPutFailed)

record

public void record(RowStatisticsImpl rowStatistics,
 Optional<byte[]> fullRegionName)

Specified by:

record in interface RowStatisticsRecorder

close

public void close()
           throws IOException

Throws:

IOException

initializeBufferedMutator

private static BufferedMutator initializeBufferedMutator(Connection conn,
 Counter rowStatisticsPutFailed)

initializeDisruptor

private static com.lmax.disruptor.dsl.Disruptor<RowStatisticsRingBufferEnvelope> initializeDisruptor(BufferedMutator bufferedMutator,
 Counter rowStatisticsPutFailures)