org.apache.hadoop.hbase.namequeues

Class SlowLogPersistentService

java.lang.Object

org.apache.hadoop.hbase.namequeues.SlowLogPersistentService

@InterfaceAudience.Private
public class SlowLogPersistentService
extends Object

Persistent service provider for Slow/LargeLog events

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 static ReentrantLock	LOCK
private static org.slf4j.Logger	LOG
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
SlowLogPersistentService(org.apache.hadoop.conf.Configuration configuration)

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	addToQueueForSysTable(org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload slowLogPayload)

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

LOCK

private static final ReentrantLock LOCK

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

queueForSysTable

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

configuration

private final org.apache.hadoop.conf.Configuration configuration

Constructor Detail

SlowLogPersistentService

public SlowLogPersistentService(org.apache.hadoop.conf.Configuration configuration)

Method Detail

addToQueueForSysTable

public void addToQueueForSysTable(org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload slowLogPayload)

addAllLogsToSysTable

public void addAllLogsToSysTable()

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