Package org.apache.hadoop.hbase.replication

Class ReplicationStorageFactory

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStorageFactory

@Private
public final class ReplicationStorageFactory
extends Object

Used to create replication storage(peer, queue) classes.

Field Summary

Fields

Modifier and Type	Field	Description
static final ReplicationPeerStorageType	DEFAULT_REPLICATION_PEER_STORAGE_IMPL
private static final org.slf4j.Logger	LOG
static final String	REPLICATION_PEER_STORAGE_IMPL
static final String	REPLICATION_QUEUE_IMPL
static final String	REPLICATION_QUEUE_TABLE_NAME
static final TableName	REPLICATION_QUEUE_TABLE_NAME_DEFAULT

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationStorageFactory()

Method Summary

Modifier and Type	Method	Description
static TableDescriptor	createReplicationQueueTableDescriptor(TableName tableName)
static ReplicationPeerStorage	getReplicationPeerStorage(org.apache.hadoop.fs.FileSystem fs, ZKWatcher zk, org.apache.hadoop.conf.Configuration conf)	Create a new ReplicationPeerStorage.
private static Class<? extends ReplicationPeerStorage>	getReplicationPeerStorageClass(org.apache.hadoop.conf.Configuration conf)
static ReplicationQueueStorage	getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf)	Create a new ReplicationQueueStorage.
static ReplicationQueueStorage	getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf, TableName tableName)	Create a new ReplicationQueueStorage.
static boolean	isReplicationQueueTable(org.apache.hadoop.conf.Configuration conf, TableName tableName)

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

REPLICATION_PEER_STORAGE_IMPL

public static final String REPLICATION_PEER_STORAGE_IMPL

See Also:

• Constant Field Values

DEFAULT_REPLICATION_PEER_STORAGE_IMPL

public static final ReplicationPeerStorageType DEFAULT_REPLICATION_PEER_STORAGE_IMPL

REPLICATION_QUEUE_TABLE_NAME

public static final String REPLICATION_QUEUE_TABLE_NAME

See Also:

• Constant Field Values

REPLICATION_QUEUE_TABLE_NAME_DEFAULT

public static final TableName REPLICATION_QUEUE_TABLE_NAME_DEFAULT

REPLICATION_QUEUE_IMPL

public static final String REPLICATION_QUEUE_IMPL

See Also:

• Constant Field Values

Constructor Details

ReplicationStorageFactory

private ReplicationStorageFactory()

Method Details

createReplicationQueueTableDescriptor

public static TableDescriptor createReplicationQueueTableDescriptor(TableName tableName)
                                                             throws IOException

Throws:

IOException

getReplicationPeerStorageClass

private static Class<? extends ReplicationPeerStorage> getReplicationPeerStorageClass(org.apache.hadoop.conf.Configuration conf)

getReplicationPeerStorage

public static ReplicationPeerStorage getReplicationPeerStorage(org.apache.hadoop.fs.FileSystem fs,
 ZKWatcher zk,
 org.apache.hadoop.conf.Configuration conf)

Create a new ReplicationPeerStorage.

getReplicationQueueStorage

public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn,
 org.apache.hadoop.conf.Configuration conf)

Create a new ReplicationQueueStorage.

getReplicationQueueStorage

public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn,
 org.apache.hadoop.conf.Configuration conf,
 TableName tableName)

Create a new ReplicationQueueStorage.

isReplicationQueueTable

public static boolean isReplicationQueueTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName)