Package org.apache.hadoop.hbase.replication.master

Class ReplicationSinkTrackerTableCreator

java.lang.Object

org.apache.hadoop.hbase.replication.master.ReplicationSinkTrackerTableCreator

@Private
public final class ReplicationSinkTrackerTableCreator
extends Object

This will create REPLICATION_SINK_TRACKER_TABLE_NAME_STR table if hbase.regionserver.replication.sink.tracker.enabled config key is enabled and table not created

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
static final byte[]	OFFSET_COLUMN
static final boolean	REPLICATION_SINK_TRACKER_ENABLED_DEFAULT
static final String	REPLICATION_SINK_TRACKER_ENABLED_KEY	Will create REPLICATION_SINK_TRACKER_TABLE_NAME_STR table if this conf is enabled
static final byte[]	REPLICATION_SINK_TRACKER_INFO_FAMILY	The REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family in array of bytes
private static final String	REPLICATION_SINK_TRACKER_INFO_FAMILY_STR	The REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family as a string
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.enabled
static final String	REPLICATION_SINK_TRACKER_TABLE_NAME_STR
static final byte[]	RS_COLUMN
private static final TableDescriptorBuilder	TABLE_DESCRIPTOR_BUILDER
static final byte[]	TIMESTAMP_COLUMN
private static final long	TTL
static final byte[]	WAL_NAME_COLUMN

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationSinkTrackerTableCreator()

Method Summary

Modifier and Type	Method	Description
static void	createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf, MasterServices masterServices)

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

TTL

private static final long TTL

RS_COLUMN

public static final byte[] RS_COLUMN

WAL_NAME_COLUMN

public static final byte[] WAL_NAME_COLUMN

TIMESTAMP_COLUMN

public static final byte[] TIMESTAMP_COLUMN

OFFSET_COLUMN

public static final byte[] OFFSET_COLUMN

REPLICATION_SINK_TRACKER_ENABLED_KEY

public static final String REPLICATION_SINK_TRACKER_ENABLED_KEY

Will create REPLICATION_SINK_TRACKER_TABLE_NAME_STR table if this conf is enabled

See Also:

• Constant Field Values

REPLICATION_SINK_TRACKER_ENABLED_DEFAULT

public static final boolean REPLICATION_SINK_TRACKER_ENABLED_DEFAULT

See Also:

• Constant Field Values

REPLICATION_SINK_TRACKER_INFO_FAMILY_STR

private static final String REPLICATION_SINK_TRACKER_INFO_FAMILY_STR

The REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family as a string

See Also:

• Constant Field Values

REPLICATION_SINK_TRACKER_INFO_FAMILY

public static final byte[] REPLICATION_SINK_TRACKER_INFO_FAMILY

The REPLICATION_SINK_TRACKER_TABLE_NAME_STR info family in array of bytes

REPLICATION_SINK_TRACKER_TABLE_NAME_STR

public static final String REPLICATION_SINK_TRACKER_TABLE_NAME_STR

See Also:

• Constant Field Values

REPLICATION_SINK_TRACKER_TABLE_NAME

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

TABLE_DESCRIPTOR_BUILDER

private static final TableDescriptorBuilder TABLE_DESCRIPTOR_BUILDER

Constructor Details

ReplicationSinkTrackerTableCreator

private ReplicationSinkTrackerTableCreator()

Method Details

createIfNeededAndNotExists

public static void createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf,
 MasterServices masterServices)
                                       throws IOException

Throws:

IOException