@InterfaceAudience.Private public final class ReplicationStorageFactory extends Object
Modifier and Type | Field and Description |
---|---|
static ReplicationPeerStorageType |
DEFAULT_REPLICATION_PEER_STORAGE_IMPL |
private static org.slf4j.Logger |
LOG |
static String |
REPLICATION_PEER_STORAGE_IMPL |
static String |
REPLICATION_QUEUE_IMPL |
static String |
REPLICATION_QUEUE_TABLE_NAME |
static TableName |
REPLICATION_QUEUE_TABLE_NAME_DEFAULT |
Modifier | Constructor and Description |
---|---|
private |
ReplicationStorageFactory() |
Modifier and Type | Method and 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) |
private static final org.slf4j.Logger LOG
public static final String REPLICATION_PEER_STORAGE_IMPL
public static final ReplicationPeerStorageType DEFAULT_REPLICATION_PEER_STORAGE_IMPL
public static final String REPLICATION_QUEUE_TABLE_NAME
public static final TableName REPLICATION_QUEUE_TABLE_NAME_DEFAULT
public static final String REPLICATION_QUEUE_IMPL
private ReplicationStorageFactory()
public static TableDescriptor createReplicationQueueTableDescriptor(TableName tableName) throws IOException
IOException
private static Class<? extends ReplicationPeerStorage> getReplicationPeerStorageClass(org.apache.hadoop.conf.Configuration conf)
public static ReplicationPeerStorage getReplicationPeerStorage(org.apache.hadoop.fs.FileSystem fs, ZKWatcher zk, org.apache.hadoop.conf.Configuration conf)
ReplicationPeerStorage
.public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf)
ReplicationQueueStorage
.public static ReplicationQueueStorage getReplicationQueueStorage(Connection conn, org.apache.hadoop.conf.Configuration conf, TableName tableName)
ReplicationQueueStorage
.public static boolean isReplicationQueueTable(org.apache.hadoop.conf.Configuration conf, TableName tableName)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.