@InterfaceAudience.Private public final class ReplicationSinkTrackerTableCreator extends Object
REPLICATION_SINK_TRACKER_TABLE_NAME_STR
table if
hbase.regionserver.replication.sink.tracker.enabled config key is enabled and table not createdModifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
static byte[] |
OFFSET_COLUMN |
static boolean |
REPLICATION_SINK_TRACKER_ENABLED_DEFAULT |
static String |
REPLICATION_SINK_TRACKER_ENABLED_KEY
Will create
REPLICATION_SINK_TRACKER_TABLE_NAME_STR table if this conf is enabled |
static byte[] |
REPLICATION_SINK_TRACKER_INFO_FAMILY
The
REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family in array of bytes |
private static String |
REPLICATION_SINK_TRACKER_INFO_FAMILY_STR
The
REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family as a string |
static TableName |
REPLICATION_SINK_TRACKER_TABLE_NAME
REPLICATION_SINK_TRACKER_TABLE_NAME_STR table name - can be enabled with config -
hbase.regionserver.replication.sink.tracker.enabled |
static String |
REPLICATION_SINK_TRACKER_TABLE_NAME_STR |
static byte[] |
RS_COLUMN |
private static TableDescriptorBuilder |
TABLE_DESCRIPTOR_BUILDER |
static byte[] |
TIMESTAMP_COLUMN |
private static long |
TTL |
static byte[] |
WAL_NAME_COLUMN |
Modifier | Constructor and Description |
---|---|
private |
ReplicationSinkTrackerTableCreator() |
Modifier and Type | Method and Description |
---|---|
static void |
createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf,
MasterServices masterServices) |
private static final org.slf4j.Logger LOG
private static final long TTL
public static final byte[] RS_COLUMN
public static final byte[] WAL_NAME_COLUMN
public static final byte[] TIMESTAMP_COLUMN
public static final byte[] OFFSET_COLUMN
public static final String REPLICATION_SINK_TRACKER_ENABLED_KEY
REPLICATION_SINK_TRACKER_TABLE_NAME_STR
table if this conf is enabledpublic static final boolean REPLICATION_SINK_TRACKER_ENABLED_DEFAULT
private static final String REPLICATION_SINK_TRACKER_INFO_FAMILY_STR
REPLICATION_SINK_TRACKER_TABLE_NAME_STR
info family as a stringpublic static final byte[] REPLICATION_SINK_TRACKER_INFO_FAMILY
REPLICATION_SINK_TRACKER_TABLE_NAME_STR
info family in array of bytespublic static final String REPLICATION_SINK_TRACKER_TABLE_NAME_STR
public static final TableName REPLICATION_SINK_TRACKER_TABLE_NAME
REPLICATION_SINK_TRACKER_TABLE_NAME_STR
table name - can be enabled with config -
hbase.regionserver.replication.sink.tracker.enabledprivate static final TableDescriptorBuilder TABLE_DESCRIPTOR_BUILDER
private ReplicationSinkTrackerTableCreator()
public static void createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf, MasterServices masterServices) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.