org.apache.hadoop.hbase.client

Class RegionReplicaUtil

java.lang.Object

org.apache.hadoop.hbase.client.RegionReplicaUtil

Direct Known Subclasses:

ServerRegionReplicaUtil

@InterfaceAudience.Private
public class RegionReplicaUtil
extends Object

Utility methods which contain the logic for regions and replicas.

Field Summary

Fields

Modifier and Type	Field and Description
protected static boolean	DEFAULT_REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH
static String	REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH_CONF_KEY Whether or not the secondary region will wait for observing a flush / region open event from the primary region via async wal replication before enabling read requests.

Constructor Summary

Constructors

Constructor and Description
RegionReplicaUtil()

Method Summary

Modifier and Type	Method and Description
static HRegionInfo	getRegionInfoForDefaultReplica(HRegionInfo regionInfo) Returns the HRegionInfo for the default replicaId (0).
static HRegionInfo	getRegionInfoForReplica(HRegionInfo regionInfo, int replicaId) Returns the HRegionInfo for the given replicaId.
static boolean	isDefaultReplica(HRegionInfo hri)
static boolean	isDefaultReplica(int replicaId)
static boolean	isReplicasForSameRegion(HRegionInfo regionInfoA, HRegionInfo regionInfoB)
static void	removeNonDefaultRegions(Collection<HRegionInfo> regions) Removes the non-default replicas from the passed regions collection

Methods inherited from class java.lang.Object

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

Field Detail

REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH_CONF_KEY

public static final String REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH_CONF_KEY

Whether or not the secondary region will wait for observing a flush / region open event from the primary region via async wal replication before enabling read requests. Since replayed edits from async wal replication from primary is not persisted in WAL, the memstore of the secondary region might be non-empty at the time of close or crash. For ensuring seqId's not "going back in time" in the secondary region replica, this should be enabled. However, in some cases the above semantics might be ok for some application classes. See HBASE-11580 for more context.

See Also:

Constant Field Values

DEFAULT_REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH

protected static final boolean DEFAULT_REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH

See Also:

Constant Field Values

Constructor Detail

RegionReplicaUtil

public RegionReplicaUtil()

Method Detail

getRegionInfoForReplica

public static HRegionInfo getRegionInfoForReplica(HRegionInfo regionInfo,
                                                  int replicaId)

Returns the HRegionInfo for the given replicaId. HRegionInfo's correspond to a range of a table, but more than one "instance" of the same range can be deployed which are differentiated by the replicaId.

Parameters:

replicaId - the replicaId to use

Returns:

an HRegionInfo object corresponding to the same range (table, start and end key), but for the given replicaId.

getRegionInfoForDefaultReplica

public static HRegionInfo getRegionInfoForDefaultReplica(HRegionInfo regionInfo)

Returns the HRegionInfo for the default replicaId (0). HRegionInfo's correspond to a range of a table, but more than one "instance" of the same range can be deployed which are differentiated by the replicaId.

Returns:

an HRegionInfo object corresponding to the same range (table, start and end key), but for the default replicaId.

isDefaultReplica

public static boolean isDefaultReplica(int replicaId)

Returns:

true if this replicaId corresponds to default replica for the region

isDefaultReplica

public static boolean isDefaultReplica(HRegionInfo hri)

Returns:

true if this region is a default replica for the region

removeNonDefaultRegions

public static void removeNonDefaultRegions(Collection<HRegionInfo> regions)

Removes the non-default replicas from the passed regions collection

Parameters:

regions -

isReplicasForSameRegion

public static boolean isReplicasForSameRegion(HRegionInfo regionInfoA,
                                              HRegionInfo regionInfoB)