public class ServerRegionReplicaUtil extends RegionReplicaUtil
RegionReplicaUtil
but for the server sideModifier and Type | Field and Description |
---|---|
static java.lang.String |
REGION_REPLICA_REPLICATION_CONF_KEY
Whether asynchronous WAL replication to the secondary region replicas is enabled or not.
|
static java.lang.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 java.lang.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_REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH, REGION_REPLICA_WAIT_FOR_PRIMARY_FLUSH_CONF_KEY
Constructor and Description |
---|
ServerRegionReplicaUtil() |
Modifier and Type | Method and Description |
---|---|
static HRegionInfo |
getRegionInfoForFs(HRegionInfo regionInfo)
Returns the regionInfo object to use for interacting with the file system.
|
static double |
getRegionReplicaStoreFileRefreshMultiplier(Configuration conf) |
static java.lang.String |
getReplicationPeerId()
Return the peer id used for replicating to secondary region replicas
|
static StoreFileInfo |
getStoreFileInfo(Configuration conf,
FileSystem fs,
HRegionInfo regionInfo,
HRegionInfo regionInfoForFs,
java.lang.String familyName,
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(Configuration conf) |
static boolean |
isRegionReplicaStoreFileRefreshEnabled(Configuration conf) |
static boolean |
isRegionReplicaWaitForPrimaryFlushEnabled(Configuration conf) |
static void |
setupRegionReplicaReplication(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.
|
getRegionInfoForDefaultReplica, getRegionInfoForReplica, isDefaultReplica, isDefaultReplica, isReplicasForSameRegion, removeNonDefaultRegions
public static final java.lang.String REGION_REPLICA_REPLICATION_CONF_KEY
public static final java.lang.String REGION_REPLICA_STORE_FILE_REFRESH
public static final java.lang.String REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER
public static HRegionInfo getRegionInfoForFs(HRegionInfo regionInfo)
public static boolean isReadOnly(HRegion region)
region
- the HRegion objectpublic static boolean shouldReplayRecoveredEdits(HRegion region)
region
- the HRegion objectpublic static StoreFileInfo getStoreFileInfo(Configuration conf, FileSystem fs, HRegionInfo regionInfo, HRegionInfo regionInfoForFs, java.lang.String familyName, Path path) throws java.io.IOException
java.io.IOException
public static void setupRegionReplicaReplication(Configuration conf) throws java.io.IOException
conf
- configuration to usejava.io.IOException
public static boolean isRegionReplicaReplicationEnabled(Configuration conf)
public static boolean isRegionReplicaWaitForPrimaryFlushEnabled(Configuration conf)
public static boolean isRegionReplicaStoreFileRefreshEnabled(Configuration conf)
public static double getRegionReplicaStoreFileRefreshMultiplier(Configuration conf)
public static java.lang.String getReplicationPeerId()