org.apache.hadoop.hbase.regionserver.slowlog

Class LogEventHandler

java.lang.Object

org.apache.hadoop.hbase.regionserver.slowlog.LogEventHandler

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<RingBufferEnvelope>

@InterfaceAudience.Private
class LogEventHandler
extends Object
implements com.lmax.disruptor.EventHandler<RingBufferEnvelope>

Event Handler run by disruptor ringbuffer consumer

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	configuration
private static int	DEFAULT_SYS_TABLE_QUEUE_SIZE
private boolean	isSlowLogTableEnabled
private static ReentrantLock	LOCK
private static org.slf4j.Logger	LOG
private Queue<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	queueForRingBuffer
private Queue<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	queueForSysTable
private static String	SYS_TABLE_QUEUE_SIZE
private static int	SYSTABLE_PUT_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
LogEventHandler(int eventCount, boolean isSlowLogTableEnabled, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
(package private) void	addAllLogsToSysTable() Poll from queueForSysTable and insert 100 records in hbase:slowlog table in single batch
(package private) boolean	clearSlowLogs() Cleans up slow log payloads
(package private) List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getLargeLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request) Retrieve list of large log payloads
private org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload.Type	getLogType(RpcLogDetails rpcCallDetails)
(package private) List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request) Retrieve list of slow log payloads
void	onEvent(RingBufferEnvelope event, long sequence, boolean endOfBatch) Called when a publisher has published an event to the RingBuffer

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

SYS_TABLE_QUEUE_SIZE

private static final String SYS_TABLE_QUEUE_SIZE

See Also:

Constant Field Values

DEFAULT_SYS_TABLE_QUEUE_SIZE

private static final int DEFAULT_SYS_TABLE_QUEUE_SIZE

See Also:

Constant Field Values

SYSTABLE_PUT_BATCH_SIZE

private static final int SYSTABLE_PUT_BATCH_SIZE

See Also:

Constant Field Values

queueForRingBuffer

private final Queue<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> queueForRingBuffer

queueForSysTable

private final Queue<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> queueForSysTable

isSlowLogTableEnabled

private final boolean isSlowLogTableEnabled

configuration

private org.apache.hadoop.conf.Configuration configuration

LOCK

private static final ReentrantLock LOCK

Constructor Detail

LogEventHandler

LogEventHandler(int eventCount,
                boolean isSlowLogTableEnabled,
                org.apache.hadoop.conf.Configuration conf)

Method Detail

onEvent

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

Called when a publisher has published an event to the RingBuffer

Specified by:

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

Parameters:

event - published to the RingBuffer

sequence - of the event being processed

endOfBatch - flag to indicate if this is the last event in a batch from the RingBuffer

Throws:

Exception - if the EventHandler would like the exception handled further up the chain

getLogType

private org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload.Type getLogType(RpcLogDetails rpcCallDetails)

clearSlowLogs

boolean clearSlowLogs()

Cleans up slow log payloads

Returns:

true if slow log payloads are cleaned up, false otherwise

getSlowLogPayloads

List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)

Retrieve list of slow log payloads

Parameters:

request - slow log request parameters

Returns:

list of slow log payloads

getLargeLogPayloads

List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> getLargeLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)

Retrieve list of large log payloads

Parameters:

request - large log request parameters

Returns:

list of large log payloads

addAllLogsToSysTable

void addAllLogsToSysTable()

Poll from queueForSysTable and insert 100 records in hbase:slowlog table in single batch