org.apache.hadoop.hbase.replication

Class ReplicationUtils

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationUtils

@InterfaceAudience.Private
public final class ReplicationUtils
extends Object

Helper class for replication.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ReplicationUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	contains(ReplicationPeerConfig peerConfig, TableName tableName) Deprecated. Will be removed in HBase 3. Use ReplicationPeerConfig.needToReplicate(TableName) instead.
static int	getAdaptiveTimeout(int initialValue, int retries) Get the adaptive timeout value when performing a retry
static org.apache.hadoop.conf.Configuration	getPeerClusterConfiguration(ReplicationPeerConfig peerConfig, org.apache.hadoop.conf.Configuration baseConf)
private static boolean	isCollectionEqual(Collection<String> c1, Collection<String> c2)
static boolean	isNamespacesAndTableCFsEqual(ReplicationPeerConfig rpc1, ReplicationPeerConfig rpc2)
private static boolean	isNamespacesEqual(Set<String> ns1, Set<String> ns2)
static boolean	isReplicationForBulkLoadDataEnabled(org.apache.hadoop.conf.Configuration c)
private static boolean	isTableCFsEqual(Map<TableName,List<String>> tableCFs1, Map<TableName,List<String>> tableCFs2)
static void	removeAllQueues(ReplicationQueueStorage queueStorage, String peerId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationUtils

private ReplicationUtils()

Method Detail

getPeerClusterConfiguration

public static org.apache.hadoop.conf.Configuration getPeerClusterConfiguration(ReplicationPeerConfig peerConfig,
                                                                               org.apache.hadoop.conf.Configuration baseConf)
                                                                        throws ReplicationException

Throws:

ReplicationException

removeAllQueues

public static void removeAllQueues(ReplicationQueueStorage queueStorage,
                                   String peerId)
                            throws ReplicationException

Throws:

ReplicationException

isCollectionEqual

private static boolean isCollectionEqual(Collection<String> c1,
                                         Collection<String> c2)

isNamespacesEqual

private static boolean isNamespacesEqual(Set<String> ns1,
                                         Set<String> ns2)

isTableCFsEqual

private static boolean isTableCFsEqual(Map<TableName,List<String>> tableCFs1,
                                       Map<TableName,List<String>> tableCFs2)

isNamespacesAndTableCFsEqual

public static boolean isNamespacesAndTableCFsEqual(ReplicationPeerConfig rpc1,
                                                   ReplicationPeerConfig rpc2)

isReplicationForBulkLoadDataEnabled

public static boolean isReplicationForBulkLoadDataEnabled(org.apache.hadoop.conf.Configuration c)

Parameters:

c - Configuration to look at

Returns:

True if replication for bulk load data is enabled.

contains

@Deprecated
public static boolean contains(ReplicationPeerConfig peerConfig,
                                           TableName tableName)

Deprecated. Will be removed in HBase 3. Use ReplicationPeerConfig.needToReplicate(TableName) instead.

Parameters:

peerConfig - configuration for the replication peer cluster

tableName - name of the table

Returns:

true if the table need replicate to the peer cluster

getAdaptiveTimeout

public static int getAdaptiveTimeout(int initialValue,
                                     int retries)

Get the adaptive timeout value when performing a retry