org.apache.hadoop.hbase.slowlog

Class SlowLogTableAccessor

java.lang.Object

org.apache.hadoop.hbase.slowlog.SlowLogTableAccessor

@InterfaceAudience.Private
public class SlowLogTableAccessor
extends Object

Slowlog Accessor to record slow/large RPC log identified at each RegionServer RpcServer level. This can be done only optionally to record the entire history of slow/large rpc calls since RingBuffer can handle only limited latest records.

Field Summary

Fields

Modifier and Type	Field and Description
private static Connection	connection
private static org.slf4j.Logger	LOG
private static Random	RANDOM
static TableName	SLOW_LOG_TABLE_NAME hbase:slowlog table name - can be enabled with config - hbase.regionserver.slowlog.systable.enabled

Constructor Summary

Constructors

Constructor and Description
SlowLogTableAccessor()

Method Summary

Modifier and Type	Method and Description
static void	addSlowLogRecords(List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads, org.apache.hadoop.conf.Configuration configuration) Add slow/large log records to hbase:slowlog table
private static void	createConnection(org.apache.hadoop.conf.Configuration configuration)
private static void	doPut(Connection connection, List<Put> puts)
private static byte[]	getRowKey(org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload slowLogPayload) Create rowKey: currentTimeMillis APPEND slowLogPayload.hashcode Scan on slowlog table should keep records with sorted order of time, however records added at the very same time (currentTimeMillis) could be in random order.

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

RANDOM

private static final Random RANDOM

connection

private static Connection connection

SLOW_LOG_TABLE_NAME

public static final TableName SLOW_LOG_TABLE_NAME

hbase:slowlog table name - can be enabled with config - hbase.regionserver.slowlog.systable.enabled

Constructor Detail

SlowLogTableAccessor

public SlowLogTableAccessor()

Method Detail

doPut

private static void doPut(Connection connection,
                          List<Put> puts)
                   throws IOException

Throws:

IOException

addSlowLogRecords

public static void addSlowLogRecords(List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads,
                                     org.apache.hadoop.conf.Configuration configuration)

Add slow/large log records to hbase:slowlog table

Parameters:

slowLogPayloads - List of SlowLogPayload to process

configuration - Configuration to use for connection

createConnection

private static void createConnection(org.apache.hadoop.conf.Configuration configuration)
                              throws IOException

Throws:

IOException

getRowKey

private static byte[] getRowKey(org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload slowLogPayload)

Create rowKey: currentTimeMillis APPEND slowLogPayload.hashcode Scan on slowlog table should keep records with sorted order of time, however records added at the very same time (currentTimeMillis) could be in random order.

Parameters:

slowLogPayload - SlowLogPayload to process

Returns:

rowKey byte[]