Package org.apache.hadoop.hbase.namequeues

Class SlowLogPersistentService

java.lang.Object

org.apache.hadoop.hbase.namequeues.SlowLogPersistentService

@Private
public class SlowLogPersistentService
extends Object

Persistent service provider for Slow/LargeLog events

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
SlowLogPersistentService(org.apache.hadoop.conf.Configuration configuration)

Method Summary

Modifier and Type	Method	Description
void	addAllLogsToSysTable(Connection connection)	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 Details

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 Details

SlowLogPersistentService

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

Method Details

addToQueueForSysTable

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

addAllLogsToSysTable

public void addAllLogsToSysTable(Connection connection)

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