org.apache.hadoop.hbase.util

Class ServerRegionReplicaUtil

java.lang.Object

org.apache.hadoop.hbase.client.RegionReplicaUtil

org.apache.hadoop.hbase.util.ServerRegionReplicaUtil

@InterfaceAudience.Private
public class ServerRegionReplicaUtil
extends RegionReplicaUtil

Similar to RegionReplicaUtil but for the server side

Field Summary

Fields

Modifier and Type	Field and Description
static String	REGION_REPLICA_REPLICATION_CONF_KEY Whether asynchronous WAL replication to the secondary region replicas is enabled or not.
static String	REGION_REPLICA_STORE_FILE_REFRESH Enables or disables refreshing store files of secondary region replicas when the memory is above the global memstore lower limit.
static String	REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER The multiplier to use when we want to refresh a secondary region instead of flushing a primary region.

Fields inherited from class org.apache.hadoop.hbase.client.RegionReplicaUtil

DEFAULT_REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH, REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH_CONF_KEY

Constructor Summary

Constructors

Constructor and Description
ServerRegionReplicaUtil()

Method Summary

Modifier and Type	Method and Description
static RegionInfo	getRegionInfoForFs(RegionInfo regionInfo) Returns the regionInfo object to use for interacting with the file system.
static double	getRegionReplicaStoreFileRefreshMultiplier(org.apache.hadoop.conf.Configuration conf)
static String	getReplicationPeerId() Return the peer id used for replicating to secondary region replicas
static StoreFileInfo	getStoreFileInfo(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, RegionInfo regionInfo, RegionInfo regionInfoForFs, String familyName, org.apache.hadoop.fs.Path path) Returns a StoreFileInfo from the given FileStatus.
static boolean	isReadOnly(HRegion region) Returns whether this region replica can accept writes.
static boolean	isRegionReplicaReplicationEnabled(org.apache.hadoop.conf.Configuration conf)
static boolean	isRegionReplicaStoreFileRefreshEnabled(org.apache.hadoop.conf.Configuration conf)
static boolean	isRegionReplicaWaitForPrimaryFlushEnabled(org.apache.hadoop.conf.Configuration conf)
static void	setupRegionReplicaReplication(org.apache.hadoop.conf.Configuration conf) Create replication peer for replicating to region replicas if needed.
static boolean	shouldReplayRecoveredEdits(HRegion region) Returns whether to replay the recovered edits to flush the results.

Methods inherited from class org.apache.hadoop.hbase.client.RegionReplicaUtil

addReplicas, getRegionInfoForDefaultReplica, getRegionInfoForReplica, isDefaultReplica, isDefaultReplica, isReplicasForSameRegion, removeNonDefaultRegions

Methods inherited from class java.lang.Object

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

Field Detail

REGION_REPLICA_REPLICATION_CONF_KEY

public static final String REGION_REPLICA_REPLICATION_CONF_KEY

Whether asynchronous WAL replication to the secondary region replicas is enabled or not. If this is enabled, a replication peer named "region_replica_replication" will be created which will tail the logs and replicate the mutatations to region replicas for tables that have region replication > 1. If this is enabled once, disabling this replication also requires disabling the replication peer using shell or Admin java class. Replication to secondary region replicas works over standard inter-cluster replication.·

See Also:

Constant Field Values

REGION_REPLICA_STORE_FILE_REFRESH

public static final String REGION_REPLICA_STORE_FILE_REFRESH

Enables or disables refreshing store files of secondary region replicas when the memory is above the global memstore lower limit. Refreshing the store files means that we will do a file list of the primary regions store files, and pick up new files. Also depending on the store files, we can drop some memstore contents which will free up memory.

See Also:

Constant Field Values

REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER

public static final String REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER

The multiplier to use when we want to refresh a secondary region instead of flushing a primary region. Default value assumes that for doing the file refresh, the biggest secondary should be 4 times bigger than the biggest primary.

See Also:

Constant Field Values

Constructor Detail

ServerRegionReplicaUtil

public ServerRegionReplicaUtil()

Method Detail

getRegionInfoForFs

public static RegionInfo getRegionInfoForFs(RegionInfo regionInfo)

Returns the regionInfo object to use for interacting with the file system.

Returns:

An RegionInfo object to interact with the filesystem

isReadOnly

public static boolean isReadOnly(HRegion region)

Returns whether this region replica can accept writes.

Parameters:

region - the HRegion object

Returns:

whether the replica is read only

shouldReplayRecoveredEdits

public static boolean shouldReplayRecoveredEdits(HRegion region)

Returns whether to replay the recovered edits to flush the results. Currently secondary region replicas do not replay the edits, since it would cause flushes which might affect the primary region. Primary regions even opened in read only mode should replay the edits.

Parameters:

region - the HRegion object

Returns:

whether recovered edits should be replayed.

getStoreFileInfo

public static StoreFileInfo getStoreFileInfo(org.apache.hadoop.conf.Configuration conf,
                                             org.apache.hadoop.fs.FileSystem fs,
                                             RegionInfo regionInfo,
                                             RegionInfo regionInfoForFs,
                                             String familyName,
                                             org.apache.hadoop.fs.Path path)
                                      throws IOException

Returns a StoreFileInfo from the given FileStatus. Secondary replicas refer to the files of the primary region, so an HFileLink is used to construct the StoreFileInfo. This way ensures that the secondary will be able to continue reading the store files even if they are moved to archive after compaction

Throws:

IOException

setupRegionReplicaReplication

public static void setupRegionReplicaReplication(org.apache.hadoop.conf.Configuration conf)
                                          throws IOException

Create replication peer for replicating to region replicas if needed.

Parameters:

conf - configuration to use

Throws:

IOException

isRegionReplicaReplicationEnabled

public static boolean isRegionReplicaReplicationEnabled(org.apache.hadoop.conf.Configuration conf)

isRegionReplicaWaitForPrimaryFlushEnabled

public static boolean isRegionReplicaWaitForPrimaryFlushEnabled(org.apache.hadoop.conf.Configuration conf)

isRegionReplicaStoreFileRefreshEnabled

public static boolean isRegionReplicaStoreFileRefreshEnabled(org.apache.hadoop.conf.Configuration conf)

getRegionReplicaStoreFileRefreshMultiplier

public static double getRegionReplicaStoreFileRefreshMultiplier(org.apache.hadoop.conf.Configuration conf)

getReplicationPeerId

public static String getReplicationPeerId()

Return the peer id used for replicating to secondary region replicas