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
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

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[]