Package org.apache.hadoop.hbase.namequeues

Class WALEventTrackerTableAccessor

java.lang.Object

org.apache.hadoop.hbase.namequeues.WALEventTrackerTableAccessor

@Private
public final class WALEventTrackerTableAccessor
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_ATTEMPTS
static final long	DEFAULT_MAX_SLEEP_TIME
static final long	DEFAULT_SLEEP_INTERVAL
static final String	DELIMITER
private static final org.slf4j.Logger	LOG
static final String	MAX_ATTEMPTS_KEY
static final String	MAX_SLEEP_TIME_KEY
static final String	RS_COLUMN
static final String	SLEEP_INTERVAL_KEY
static final String	TIMESTAMP_COLUMN
static final TableName	WAL_EVENT_TRACKER_TABLE_NAME	WAL_EVENT_TRACKER_TABLE_NAME_STR table name - can be enabled with config - hbase.regionserver.wal.event.tracker.enabled
static final String	WAL_EVENT_TRACKER_TABLE_NAME_STR
static final String	WAL_LENGTH_COLUMN
static final String	WAL_NAME_COLUMN
static final String	WAL_STATE_COLUMN

Constructor Summary

Constructors

Modifier	Constructor	Description
private	WALEventTrackerTableAccessor()

Method Summary

Modifier and Type	Method	Description
static void	addWalEventTrackerRows(Queue<WALEventTrackerPayload> walEventPayloads, Connection connection)	Add wal event tracker rows to hbase:waleventtracker table
private static void	doPut(Connection connection, List<Put> puts)
private static RetryCounterFactory	getRetryFactory(org.apache.hadoop.conf.Configuration conf)
static byte[]	getRowKey(WALEventTrackerPayload payload)	Create rowKey: 1.
private static void	retryOrThrow(RetryCounter retryCounter, IOException ioe)

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

RS_COLUMN

public static final String RS_COLUMN

See Also:

• Constant Field Values

WAL_NAME_COLUMN

public static final String WAL_NAME_COLUMN

See Also:

• Constant Field Values

TIMESTAMP_COLUMN

public static final String TIMESTAMP_COLUMN

See Also:

• Constant Field Values

WAL_STATE_COLUMN

public static final String WAL_STATE_COLUMN

See Also:

• Constant Field Values

WAL_LENGTH_COLUMN

public static final String WAL_LENGTH_COLUMN

See Also:

• Constant Field Values

MAX_ATTEMPTS_KEY

public static final String MAX_ATTEMPTS_KEY

See Also:

• Constant Field Values

SLEEP_INTERVAL_KEY

public static final String SLEEP_INTERVAL_KEY

See Also:

• Constant Field Values

MAX_SLEEP_TIME_KEY

public static final String MAX_SLEEP_TIME_KEY

See Also:

• Constant Field Values

DEFAULT_MAX_ATTEMPTS

public static final int DEFAULT_MAX_ATTEMPTS

See Also:

• Constant Field Values

DEFAULT_SLEEP_INTERVAL

public static final long DEFAULT_SLEEP_INTERVAL

See Also:

• Constant Field Values

DEFAULT_MAX_SLEEP_TIME

public static final long DEFAULT_MAX_SLEEP_TIME

See Also:

• Constant Field Values

WAL_EVENT_TRACKER_TABLE_NAME_STR

public static final String WAL_EVENT_TRACKER_TABLE_NAME_STR

See Also:

• Constant Field Values

DELIMITER

public static final String DELIMITER

See Also:

• Constant Field Values

WAL_EVENT_TRACKER_TABLE_NAME

public static final TableName WAL_EVENT_TRACKER_TABLE_NAME

WAL_EVENT_TRACKER_TABLE_NAME_STR table name - can be enabled with config - hbase.regionserver.wal.event.tracker.enabled

Constructor Details

WALEventTrackerTableAccessor

private WALEventTrackerTableAccessor()

Method Details

doPut

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

Throws:

Exception

getRetryFactory

private static RetryCounterFactory getRetryFactory(org.apache.hadoop.conf.Configuration conf)

retryOrThrow

private static void retryOrThrow(RetryCounter retryCounter,
 IOException ioe)
                          throws IOException

Throws:

IOException

addWalEventTrackerRows

public static void addWalEventTrackerRows(Queue<WALEventTrackerPayload> walEventPayloads,
 Connection connection)
                                   throws Exception

Add wal event tracker rows to hbase:waleventtracker table

Parameters:

walEventPayloads - List of walevents to process

connection - Connection to use.

Throws:

Exception

getRowKey

public static byte[] getRowKey(WALEventTrackerPayload payload)

Create rowKey: 1. We want RS name to be the leading part of rowkey so that we can query by RS name filter. WAL name contains rs name as a leading part. 2. Timestamp when the event was generated. 3. Add state of the wal. Combination of 1 + 2 + 3 is definitely going to create a unique rowkey.

Parameters:

payload - payload to process

Returns:

rowKey byte[]