Package org.apache.hadoop.hbase.replication

Class ReplicationUtils

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationUtils

@Private
public final class ReplicationUtils
extends Object

Helper class for replication.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LEGACY_REGION_REPLICATION_ENDPOINT_NAME
private static final org.slf4j.Logger	LOG
static final String	REMOTE_WAL_DIR_NAME
static final String	REMOTE_WAL_REPLAY_SUFFIX
static final String	REMOTE_WAL_SNAPSHOT_SUFFIX
static final String	RENAME_WAL_SUFFIX
static final String	REPLICATION_ATTR_NAME
static final String	SYNC_WAL_SUFFIX

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationUtils()

Method Summary

Modifier and Type	Method	Description
static int	getAdaptiveTimeout(int initialValue, int retries)	Get the adaptive timeout value when performing a retry
static org.apache.hadoop.fs.Path	getPeerRemoteWALDir(String remoteWALDir, String peerId)
static org.apache.hadoop.fs.Path	getPeerRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
static org.apache.hadoop.fs.Path	getPeerReplayWALDir(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
static org.apache.hadoop.fs.Path	getPeerSnapshotWALDir(String remoteWALDir, String peerId)
static org.apache.hadoop.fs.Path	getPeerSnapshotWALDir(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
static org.apache.hadoop.fs.FileSystem	getRemoteWALFileSystem(org.apache.hadoop.conf.Configuration conf, String remoteWALDir)
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 boolean	sleepForRetries(String msg, long sleepForRetries, int sleepMultiplier, int maxRetriesMultiplier)	Do the sleeping logic

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_ATTR_NAME

public static final String REPLICATION_ATTR_NAME

See Also:

• Constant Field Values

REMOTE_WAL_DIR_NAME

public static final String REMOTE_WAL_DIR_NAME

See Also:

• Constant Field Values

SYNC_WAL_SUFFIX

public static final String SYNC_WAL_SUFFIX

See Also:

• Constant Field Values

REMOTE_WAL_REPLAY_SUFFIX

public static final String REMOTE_WAL_REPLAY_SUFFIX

See Also:

• Constant Field Values

REMOTE_WAL_SNAPSHOT_SUFFIX

public static final String REMOTE_WAL_SNAPSHOT_SUFFIX

See Also:

• Constant Field Values

RENAME_WAL_SUFFIX

public static final String RENAME_WAL_SUFFIX

See Also:

• Constant Field Values

LEGACY_REGION_REPLICATION_ENDPOINT_NAME

public static final String LEGACY_REGION_REPLICATION_ENDPOINT_NAME

See Also:

• Constant Field Values

Constructor Details

ReplicationUtils

private ReplicationUtils()

Method Details

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.

getRemoteWALFileSystem

public static org.apache.hadoop.fs.FileSystem getRemoteWALFileSystem(org.apache.hadoop.conf.Configuration conf,
 String remoteWALDir)
                                                              throws IOException

Throws:

IOException

getPeerRemoteWALDir

public static org.apache.hadoop.fs.Path getPeerRemoteWALDir(String remoteWALDir,
 String peerId)

getPeerRemoteWALDir

public static org.apache.hadoop.fs.Path getPeerRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir,
 String peerId)

getPeerReplayWALDir

public static org.apache.hadoop.fs.Path getPeerReplayWALDir(org.apache.hadoop.fs.Path remoteWALDir,
 String peerId)

getPeerSnapshotWALDir

public static org.apache.hadoop.fs.Path getPeerSnapshotWALDir(String remoteWALDir,
 String peerId)

getPeerSnapshotWALDir

public static org.apache.hadoop.fs.Path getPeerSnapshotWALDir(org.apache.hadoop.fs.Path remoteWALDir,
 String peerId)

sleepForRetries

public static boolean sleepForRetries(String msg,
 long sleepForRetries,
 int sleepMultiplier,
 int maxRetriesMultiplier)

Do the sleeping logic

Parameters:

msg - Why we sleep

sleepForRetries - the base sleep time.

sleepMultiplier - by how many times the default sleeping time is augmented

maxRetriesMultiplier - the max retry multiplier

Returns:

True if sleepMultiplier is < maxRetriesMultiplier

getAdaptiveTimeout

public static int getAdaptiveTimeout(int initialValue,
 int retries)

Get the adaptive timeout value when performing a retry