Class ReplicationStorageFactory
java.lang.Object
org.apache.hadoop.hbase.replication.ReplicationStorageFactory
Used to create replication storage(peer, queue) classes.
-
Field Summary
Modifier and TypeFieldDescriptionstatic final ReplicationPeerStorageType
private static final org.slf4j.Logger
static final String
static final String
static final String
static final TableName
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic TableDescriptor
createReplicationQueueTableDescriptor
(TableName tableName) static ReplicationPeerStorage
getReplicationPeerStorage
(org.apache.hadoop.fs.FileSystem fs, ZKWatcher zk, org.apache.hadoop.conf.Configuration conf) Create a newReplicationPeerStorage
.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 newReplicationQueueStorage
.static ReplicationQueueStorage
getReplicationQueueStorage
(Connection conn, org.apache.hadoop.conf.Configuration conf, TableName tableName) Create a newReplicationQueueStorage
.static boolean
isReplicationQueueTable
(org.apache.hadoop.conf.Configuration conf, TableName tableName)
-
Field Details
-
LOG
-
REPLICATION_PEER_STORAGE_IMPL
- See Also:
-
DEFAULT_REPLICATION_PEER_STORAGE_IMPL
-
REPLICATION_QUEUE_TABLE_NAME
- See Also:
-
REPLICATION_QUEUE_TABLE_NAME_DEFAULT
-
REPLICATION_QUEUE_IMPL
- See Also:
-
-
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 newReplicationPeerStorage
. -
getReplicationQueueStorage
public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf) Create a newReplicationQueueStorage
. -
getReplicationQueueStorage
public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf, TableName tableName) Create a newReplicationQueueStorage
. -
isReplicationQueueTable
public static boolean isReplicationQueueTable(org.apache.hadoop.conf.Configuration conf, TableName tableName)
-