Package org.apache.hadoop.hbase.namequeues.impl

Class SlowLogQueueService

java.lang.Object

org.apache.hadoop.hbase.namequeues.impl.SlowLogQueueService

All Implemented Interfaces:

NamedQueueService

@Private
public class SlowLogQueueService
extends Object
implements NamedQueueService

In-memory Queue service provider for Slow/LargeLog events

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	isOnlineLogProviderEnabled
private final boolean	isSlowLogTableEnabled
private static final org.slf4j.Logger	LOG
private static final String	SLOW_LOG_RING_BUFFER_SIZE
private final SlowLogPersistentService	slowLogPersistentService
private final Queue<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	slowLogQueue
private final boolean	slowLogScanPayloadEnabled

Constructor Summary

Constructors

Constructor	Description
SlowLogQueueService(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private static Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair>	buildNameBytesPairs(Map<String,byte[]> attributes)
boolean	clearNamedQueue()	Cleans up queues maintained by services.
void	consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload)	This implementation is specific to slowLog event.
NamedQueuePayload.NamedQueueEvent	getEvent()	Retrieve event type for NamedQueueService implementation.
private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getLargeLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)
private org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload.Type	getLogType(RpcLogDetails rpcCallDetails)
NamedQueueGetResponse	getNamedQueueRecords(NamedQueueGetRequest request)	Retrieve in memory queue records from ringbuffer
private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request)
void	persistAll(Connection connection)	Add all slowLog events to system table.

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

SLOW_LOG_RING_BUFFER_SIZE

private static final String SLOW_LOG_RING_BUFFER_SIZE

See Also:

• Constant Field Values

isOnlineLogProviderEnabled

private final boolean isOnlineLogProviderEnabled

isSlowLogTableEnabled

private final boolean isSlowLogTableEnabled

slowLogPersistentService

private final SlowLogPersistentService slowLogPersistentService

slowLogQueue

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

slowLogScanPayloadEnabled

private final boolean slowLogScanPayloadEnabled

Constructor Details

SlowLogQueueService

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

Method Details

getEvent

public NamedQueuePayload.NamedQueueEvent getEvent()

Description copied from interface: NamedQueueService

Retrieve event type for NamedQueueService implementation.

Specified by:

getEvent in interface NamedQueueService

Returns:

NamedQueuePayload.NamedQueueEvent

consumeEventFromDisruptor

public void consumeEventFromDisruptor(NamedQueuePayload namedQueuePayload)

This implementation is specific to slowLog event. This consumes slowLog event from disruptor and inserts records to EvictingQueue.

Specified by:

consumeEventFromDisruptor in interface NamedQueueService

Parameters:

namedQueuePayload - namedQueue payload from disruptor ring buffer

buildNameBytesPairs

private static Collection<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.NameBytesPair> buildNameBytesPairs(Map<String,byte[]> attributes)

clearNamedQueue

public boolean clearNamedQueue()

Description copied from interface: NamedQueueService

Cleans up queues maintained by services.

Specified by:

clearNamedQueue in interface NamedQueueService

Returns:

true if slow log payloads are cleaned up, false otherwise

getNamedQueueRecords

public NamedQueueGetResponse getNamedQueueRecords(NamedQueueGetRequest request)

Description copied from interface: NamedQueueService

Retrieve in memory queue records from ringbuffer

Specified by:

getNamedQueueRecords in interface NamedQueueService

Parameters:

request - namedQueue request with event type

Returns:

queue records from ringbuffer after filter (if applied)

getLogType

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

persistAll

public void persistAll(Connection connection)

Add all slowLog events to system table. This is only for slowLog event's persistence on system table.

Specified by:

persistAll in interface NamedQueueService

getSlowLogPayloads

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

getLargeLogPayloads

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