Package org.apache.hadoop.hbase.namequeues

Class NamedQueueServiceChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.namequeues.NamedQueueServiceChore

All Implemented Interfaces:

Runnable

@Private
public class NamedQueueServiceChore
extends ScheduledChore

Chore to insert multiple accumulated slow/large logs to hbase:slowlog system table

Field Summary

Fields

Modifier and Type	Field	Description
private final Connection	connection
private static final org.slf4j.Logger	LOG
static final int	NAMED_QUEUE_CHORE_DURATION_DEFAULT
static final String	NAMED_QUEUE_CHORE_DURATION_KEY
private final NamedQueueRecorder	namedQueueRecorder

Constructor Summary

Constructors

Constructor	Description
NamedQueueServiceChore(Stoppable stopper, int period, NamedQueueRecorder namedQueueRecorder, Connection connection)	Chore Constructor

Method Summary

Modifier and Type	Method	Description
protected void	chore()	The task to execute on each scheduled execution of the Chore

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

NAMED_QUEUE_CHORE_DURATION_KEY

public static final String NAMED_QUEUE_CHORE_DURATION_KEY

See Also:

• Constant Field Values

NAMED_QUEUE_CHORE_DURATION_DEFAULT

public static final int NAMED_QUEUE_CHORE_DURATION_DEFAULT

See Also:

• Constant Field Values

namedQueueRecorder

private final NamedQueueRecorder namedQueueRecorder

connection

private final Connection connection

Constructor Details

NamedQueueServiceChore

public NamedQueueServiceChore(Stoppable stopper,
 int period,
 NamedQueueRecorder namedQueueRecorder,
 Connection connection)

Chore Constructor

Parameters:

stopper - The stopper - When Stoppable.isStopped() is true, this chore will cancel and cleanup

period - Period in millis with which this Chore repeats execution when scheduled

namedQueueRecorder - NamedQueueRecorder instance

Method Details

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore