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
static final String	REPLICATION_PEER_STORAGE_IMPL

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationStorageFactory()

Method Summary

Modifier and Type	Method	Description
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(ZKWatcher zk, org.apache.hadoop.conf.Configuration conf)	Create a new ReplicationQueueStorage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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

Constructor Details

ReplicationStorageFactory

private ReplicationStorageFactory()

Method Details

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(ZKWatcher zk,
 org.apache.hadoop.conf.Configuration conf)

Create a new ReplicationQueueStorage.