Package org.apache.hadoop.hbase.master.assignment

Class RegionStateStore

java.lang.Object

org.apache.hadoop.hbase.master.assignment.RegionStateStore

@Private
public class RegionStateStore
extends Object

Store Region State to hbase:meta table.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RegionStateStore.RegionStateVisitor

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final MasterServices	master
private final MasterRegion	masterRegion
protected static final char	META_REPLICA_ID_DELIMITER	The delimiter for meta columns for replicaIds > 0
private static final org.slf4j.Logger	METALOG

Constructor Summary

Constructors

Constructor	Description
RegionStateStore(MasterServices master, MasterRegion masterRegion)

Method Summary

Modifier and Type	Method	Description
(package private) static Put	addMergeRegions(Put put, Collection<RegionInfo> mergeRegions)
private static Put	addSequenceNum(Put p, long openSeqNum, int replicaId)
private static void	debugLogMutation(Mutation p)
private static void	debugLogMutations(List<? extends Mutation> mutations)
void	deleteMergeQualifiers(RegionInfo mergeRegion)	Deletes merge qualifiers for the specified merge region.
void	deleteRegion(RegionInfo regionInfo)	Deletes the specified region.
private List<Delete>	deleteRegionReplicas(ResultScanner scanner, int oldReplicaCount, int newReplicaCount, long now)
void	deleteRegions(List<RegionInfo> regions)	Deletes the specified regions.
private void	deleteRegions(List<RegionInfo> regions, long ts)
private Put	generateUpdateRegionLocationPut(RegionStateNode regionStateNode)
private TableDescriptor	getDescriptor(TableName tableName)
List<RegionInfo>	getMergeRegions(RegionInfo region)	Returns Return all regioninfos listed in the 'info:merge*' columns of the given region.
private Table	getMetaTable()
private long	getOpenSeqNumForParentRegion(RegionInfo region)
private Result	getRegionCatalogResult(RegionInfo region)
private int	getRegionReplication(TableDescriptor htd)
static RegionState.State	getRegionState(Result r, RegionInfo regionInfo)	Pull the region state from a catalog table Result.
private Scan	getScanForUpdateRegionReplicas(TableName tableName)
static byte[]	getStateColumn(int replicaId)
private boolean	hasGlobalReplicationScope(TableDescriptor htd)
private boolean	hasGlobalReplicationScope(TableName tableName)
boolean	hasMergeRegions(RegionInfo region)	Check whether the given region has any 'info:merge*' columns.
void	mergeRegions(RegionInfo child, RegionInfo[] parents, ServerName serverName, TableDescriptor htd)
private void	mirrorMetaLocation(RegionInfo regionInfo, ServerName serverName, RegionState.State state)
private void	multiMutate(RegionInfo ri, List<Mutation> mutations)	Performs an atomic multi-mutate operation against the given table.
void	overwriteRegions(List<RegionInfo> regionInfos, int regionReplication)	Overwrites the specified regions from hbase:meta.
private void	removeMirrorMetaLocation(int oldReplicaCount, int newReplicaCount)
void	removeRegionReplicas(TableName tableName, int oldReplicaCount, int newReplicaCount)
void	splitRegion(RegionInfo parent, RegionInfo splitA, RegionInfo splitB, ServerName serverName, TableDescriptor htd)	Splits the region into two in an atomic operation.
private CompletableFuture<Void>	updateRegionLocation(RegionInfo regionInfo, RegionState.State state, Put put)
(package private) CompletableFuture<Void>	updateRegionLocation(RegionStateNode regionStateNode)
void	visitMeta(RegionStateStore.RegionStateVisitor visitor)
static void	visitMetaEntry(RegionStateStore.RegionStateVisitor visitor, Result result)
void	visitMetaForRegion(String regionEncodedName, RegionStateStore.RegionStateVisitor visitor)	Queries META table for the passed region encoded name, delegating action upon results to the RegionStateVisitor passed as second parameter.

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

METALOG

private static final org.slf4j.Logger METALOG

META_REPLICA_ID_DELIMITER

protected static final char META_REPLICA_ID_DELIMITER

The delimiter for meta columns for replicaIds > 0

See Also:

• Constant Field Values

master

private final MasterServices master

masterRegion

private final MasterRegion masterRegion

Constructor Details

RegionStateStore

public RegionStateStore(MasterServices master,
 MasterRegion masterRegion)

Method Details

visitMeta

public void visitMeta(RegionStateStore.RegionStateVisitor visitor)
               throws IOException

Throws:

IOException

visitMetaForRegion

public void visitMetaForRegion(String regionEncodedName,
 RegionStateStore.RegionStateVisitor visitor)
                        throws IOException

Queries META table for the passed region encoded name, delegating action upon results to the RegionStateVisitor passed as second parameter.

Parameters:

regionEncodedName - encoded name for the Region we want to query META for.

visitor - The RegionStateVisitor instance to react over the query results.

Throws:

IOException - If some error occurs while querying META or parsing results.

visitMetaEntry

public static void visitMetaEntry(RegionStateStore.RegionStateVisitor visitor,
 Result result)
                           throws IOException

Throws:

IOException

generateUpdateRegionLocationPut

private Put generateUpdateRegionLocationPut(RegionStateNode regionStateNode)
                                     throws IOException

Throws:

IOException

updateRegionLocation

CompletableFuture<Void> updateRegionLocation(RegionStateNode regionStateNode)

mirrorMetaLocation

private void mirrorMetaLocation(RegionInfo regionInfo,
 ServerName serverName,
 RegionState.State state)
                         throws IOException

Throws:

IOException

removeMirrorMetaLocation

private void removeMirrorMetaLocation(int oldReplicaCount,
 int newReplicaCount)
                               throws IOException

Throws:

IOException

updateRegionLocation

private CompletableFuture<Void> updateRegionLocation(RegionInfo regionInfo,
 RegionState.State state,
 Put put)

getOpenSeqNumForParentRegion

private long getOpenSeqNumForParentRegion(RegionInfo region)
                                   throws IOException

Throws:

IOException

multiMutate

private void multiMutate(RegionInfo ri,
 List<Mutation> mutations)
                  throws IOException

Performs an atomic multi-mutate operation against the given table. Used by the likes of merge and split as these want to make atomic mutations across multiple rows.

Throws:

IOException

getMetaTable

private Table getMetaTable()
                    throws IOException

Throws:

IOException

getRegionCatalogResult

private Result getRegionCatalogResult(RegionInfo region)
                               throws IOException

Throws:

IOException

addSequenceNum

private static Put addSequenceNum(Put p,
 long openSeqNum,
 int replicaId)
                           throws IOException

Throws:

IOException

splitRegion

public void splitRegion(RegionInfo parent,
 RegionInfo splitA,
 RegionInfo splitB,
 ServerName serverName,
 TableDescriptor htd)
                 throws IOException

Splits the region into two in an atomic operation. Offlines the parent region with the information that it is split into two, and also adds the daughter regions. Does not add the location information to the daughter regions since they are not open yet.

Throws:

IOException

mergeRegions

public void mergeRegions(RegionInfo child,
 RegionInfo[] parents,
 ServerName serverName,
 TableDescriptor htd)
                  throws IOException

Throws:

IOException

hasMergeRegions

public boolean hasMergeRegions(RegionInfo region)
                        throws IOException

Check whether the given region has any 'info:merge*' columns.

Throws:

IOException

getMergeRegions

public List<RegionInfo> getMergeRegions(RegionInfo region)
                                 throws IOException

Returns Return all regioninfos listed in the 'info:merge*' columns of the given region.

Throws:

IOException

deleteMergeQualifiers

public void deleteMergeQualifiers(RegionInfo mergeRegion)
                           throws IOException

Deletes merge qualifiers for the specified merge region.

Parameters:

connection - connection we're using

mergeRegion - the merged region

Throws:

IOException

addMergeRegions

static Put addMergeRegions(Put put,
 Collection<RegionInfo> mergeRegions)
                    throws IOException

Throws:

IOException

deleteRegion

public void deleteRegion(RegionInfo regionInfo)
                  throws IOException

Deletes the specified region.

Throws:

IOException

deleteRegions

public void deleteRegions(List<RegionInfo> regions)
                   throws IOException

Deletes the specified regions.

Throws:

IOException

deleteRegions

private void deleteRegions(List<RegionInfo> regions,
 long ts)
                    throws IOException

Throws:

IOException

overwriteRegions

public void overwriteRegions(List<RegionInfo> regionInfos,
 int regionReplication)
                      throws IOException

Overwrites the specified regions from hbase:meta. Deletes old rows for the given regions and adds new ones. Regions added back have state CLOSED.

Parameters:

connection - connection we're using

regionInfos - list of regions to be added to META

Throws:

IOException

getScanForUpdateRegionReplicas

private Scan getScanForUpdateRegionReplicas(TableName tableName)

deleteRegionReplicas

private List<Delete> deleteRegionReplicas(ResultScanner scanner,
 int oldReplicaCount,
 int newReplicaCount,
 long now)
                                   throws IOException

Throws:

IOException

removeRegionReplicas

public void removeRegionReplicas(TableName tableName,
 int oldReplicaCount,
 int newReplicaCount)
                          throws IOException

Throws:

IOException

hasGlobalReplicationScope

private boolean hasGlobalReplicationScope(TableName tableName)
                                   throws IOException

Throws:

IOException

hasGlobalReplicationScope

private boolean hasGlobalReplicationScope(TableDescriptor htd)

getRegionReplication

private int getRegionReplication(TableDescriptor htd)

getDescriptor

private TableDescriptor getDescriptor(TableName tableName)
                               throws IOException

Throws:

IOException

getRegionState

public static RegionState.State getRegionState(Result r,
 RegionInfo regionInfo)

Pull the region state from a catalog table Result.

Returns:

the region state, or null if unknown.

getStateColumn

public static byte[] getStateColumn(int replicaId)

debugLogMutations

private static void debugLogMutations(List<? extends Mutation> mutations)
                               throws IOException

Throws:

IOException

debugLogMutation

private static void debugLogMutation(Mutation p)
                              throws IOException

Throws:

IOException