@InterfaceAudience.Private public final class WALEventTrackerTableAccessor extends Object
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_ATTEMPTS |
static long |
DEFAULT_MAX_SLEEP_TIME |
static long |
DEFAULT_SLEEP_INTERVAL |
static String |
DELIMITER |
private static org.slf4j.Logger |
LOG |
static String |
MAX_ATTEMPTS_KEY |
static String |
MAX_SLEEP_TIME_KEY |
static String |
RS_COLUMN |
static String |
SLEEP_INTERVAL_KEY |
static String |
TIMESTAMP_COLUMN |
static 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 String |
WAL_EVENT_TRACKER_TABLE_NAME_STR |
static String |
WAL_LENGTH_COLUMN |
static String |
WAL_NAME_COLUMN |
static String |
WAL_STATE_COLUMN |
Modifier | Constructor and Description |
---|---|
private |
WALEventTrackerTableAccessor() |
Modifier and Type | Method and 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) |
private static final org.slf4j.Logger LOG
public static final String RS_COLUMN
public static final String WAL_NAME_COLUMN
public static final String TIMESTAMP_COLUMN
public static final String WAL_STATE_COLUMN
public static final String WAL_LENGTH_COLUMN
public static final String MAX_ATTEMPTS_KEY
public static final String SLEEP_INTERVAL_KEY
public static final String MAX_SLEEP_TIME_KEY
public static final int DEFAULT_MAX_ATTEMPTS
public static final long DEFAULT_SLEEP_INTERVAL
public static final long DEFAULT_MAX_SLEEP_TIME
public static final String WAL_EVENT_TRACKER_TABLE_NAME_STR
public static final String DELIMITER
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.enabledprivate WALEventTrackerTableAccessor()
private static void doPut(Connection connection, List<Put> puts) throws Exception
Exception
private static RetryCounterFactory getRetryFactory(org.apache.hadoop.conf.Configuration conf)
private static void retryOrThrow(RetryCounter retryCounter, IOException ioe) throws IOException
IOException
public static void addWalEventTrackerRows(Queue<WALEventTrackerPayload> walEventPayloads, Connection connection) throws Exception
walEventPayloads
- List of walevents to processconnection
- Connection to use.Exception
public static byte[] getRowKey(WALEventTrackerPayload payload)
payload
- payload to processCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.