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 ReplicationAdmin java class. Replication to secondary region replicas works over standard inter-cluster replication.· So replication, if disabled explicitly, also has to be enabled by setting "hbase.replication"· to true for this feature to work.

  See Also:

  Constant Field Values

• DEFAULT_REGION_REPLICA_REPLICATION

  private static final boolean DEFAULT_REGION_REPLICA_REPLICATION

  See Also:

  Constant Field Values

• REGION_REPLICA_REPLICATION_PEER

  private static final String REGION_REPLICA_REPLICATION_PEER

  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

• DEFAULT_REGION_REPLICA_STORE_FILE_REFRESH

  private static final boolean DEFAULT_REGION_REPLICA_STORE_FILE_REFRESH

  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

• DEFAULT_REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER

  private static final double DEFAULT_REGION_REPLICA_STORE_FILE_REFRESH_MEMSTORE_MULTIPLIER

  See Also:

  Constant Field Values

Constructor Detail

• ServerRegionReplicaUtil

  public ServerRegionReplicaUtil()

Method Detail

• getRegionInfoForFs

  public static HRegionInfo getRegionInfoForFs(HRegionInfo regionInfo)

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

  Returns:

  An HRegionInfo 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,
                               HRegionInfo regionInfo,
                               HRegionInfo 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