org.apache.hadoop.hbase.regionserver.slowlog

Class SlowLogRecorder

java.lang.Object

org.apache.hadoop.hbase.regionserver.slowlog.SlowLogRecorder

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class SlowLogRecorder
extends Object

Online Slow/Large Log Provider Service that keeps slow/large RPC logs in the ring buffer. The service uses LMAX Disruptor to save slow records which are then consumed by a queue and based on the ring buffer size, the available records are then fetched from the queue in thread-safe manner.

Field Summary

Fields

Modifier and Type	Field and Description
private com.lmax.disruptor.dsl.Disruptor<RingBufferEnvelope>	disruptor
private int	eventCount
private boolean	isOnlineLogProviderEnabled
private LogEventHandler	logEventHandler
private static String	SLOW_LOG_RING_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
SlowLogRecorder(org.apache.hadoop.conf.Configuration conf) Initialize disruptor with configurable ringbuffer size

Method Summary

Modifier and Type	Method and Description
void	addAllLogsToSysTable() Poll from queueForSysTable and insert 100 records in hbase:slowlog table in single batch
void	addSlowLogPayload(RpcLogDetails rpcLogDetails) Add slow log rpcCall details to ringbuffer
boolean	clearSlowLogPayloads() clears slow log payloads from ringbuffer
private int	getEventCount()
List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getLargeLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request) Retrieve online large logs from ringbuffer
List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request) Retrieve online slow logs from ringbuffer

Methods inherited from class java.lang.Object

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

Field Detail

disruptor

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

logEventHandler

private final LogEventHandler logEventHandler

eventCount

private final int eventCount

isOnlineLogProviderEnabled

private final boolean isOnlineLogProviderEnabled

SLOW_LOG_RING_BUFFER_SIZE

private static final String SLOW_LOG_RING_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

SlowLogRecorder

public SlowLogRecorder(org.apache.hadoop.conf.Configuration conf)

Initialize disruptor with configurable ringbuffer size

Method Detail

getEventCount

private int getEventCount()

getSlowLogPayloads

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

Retrieve online slow logs from ringbuffer

Parameters:

request - slow log request parameters

Returns:

online slow logs from ringbuffer

getLargeLogPayloads

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

Retrieve online large logs from ringbuffer

Parameters:

request - large log request parameters

Returns:

online large logs from ringbuffer

clearSlowLogPayloads

public boolean clearSlowLogPayloads()

clears slow log payloads from ringbuffer

Returns:

true if slow log payloads are cleaned up or hbase.regionserver.slowlog.buffer.enabled is not set to true, false if failed to clean up slow logs

addSlowLogPayload

public void addSlowLogPayload(RpcLogDetails rpcLogDetails)

Add slow log rpcCall details to ringbuffer

Parameters:

rpcLogDetails - all details of rpc call that would be useful for ring buffer consumers

addAllLogsToSysTable

public void addAllLogsToSysTable()

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