org.apache.hadoop.hbase.master.assignment

Class RegionStateStore

java.lang.Object

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

@InterfaceAudience.Private
public class RegionStateStore
extends Object

Store Region State to hbase:meta table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RegionStateStore.RegionStateVisitor

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
RegionStateStore(MasterServices master)

Method Summary

Modifier and Type	Method and Description
void	deleteRegion(RegionInfo regionInfo)
void	deleteRegions(List<RegionInfo> regions)
private long	getOpenSeqNumForParentRegion(RegionInfo region)
private int	getRegionReplication(TableDescriptor htd)
(package private) static ServerName	getRegionServer(Result r, int replicaId) Returns the ServerName from catalog table Result where the region is transitioning.
static RegionState.State	getRegionState(Result r, RegionInfo regionInfo) Pull the region state from a catalog table Result.
private static byte[]	getServerNameColumn(int replicaId)
private static byte[]	getStateColumn(int replicaId)
private TableDescriptor	getTableDescriptor(TableName tableName)
private boolean	hasGlobalReplicationScope(TableDescriptor htd)
private boolean	hasGlobalReplicationScope(TableName tableName)
void	mergeRegions(RegionInfo child, RegionInfo[] parents, ServerName serverName)
void	splitRegion(RegionInfo parent, RegionInfo hriA, RegionInfo hriB, ServerName serverName)
private void	updateMetaLocation(RegionInfo regionInfo, ServerName serverName, RegionState.State state)
private void	updateRegionLocation(RegionInfo regionInfo, RegionState.State state, Put put)
void	updateRegionLocation(RegionStateNode regionStateNode)
private void	updateUserRegionLocation(RegionInfo regionInfo, RegionState.State state, ServerName regionLocation, long openSeqNum, long pid)
void	visitMeta(RegionStateStore.RegionStateVisitor visitor)
private void	visitMetaEntry(RegionStateStore.RegionStateVisitor visitor, Result result)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

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

Constructor Detail

RegionStateStore

public RegionStateStore(MasterServices master)

Method Detail

visitMeta

public void visitMeta(RegionStateStore.RegionStateVisitor visitor)
               throws IOException

Throws:

IOException

visitMetaEntry

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

Throws:

IOException

updateRegionLocation

public void updateRegionLocation(RegionStateNode regionStateNode)
                          throws IOException

Throws:

IOException

updateMetaLocation

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

Throws:

IOException

updateUserRegionLocation

private void updateUserRegionLocation(RegionInfo regionInfo,
                                      RegionState.State state,
                                      ServerName regionLocation,
                                      long openSeqNum,
                                      long pid)
                               throws IOException

Throws:

IOException

updateRegionLocation

private void updateRegionLocation(RegionInfo regionInfo,
                                  RegionState.State state,
                                  Put put)
                           throws IOException

Throws:

IOException

getOpenSeqNumForParentRegion

private long getOpenSeqNumForParentRegion(RegionInfo region)
                                   throws IOException

Throws:

IOException

splitRegion

public void splitRegion(RegionInfo parent,
                        RegionInfo hriA,
                        RegionInfo hriB,
                        ServerName serverName)
                 throws IOException

Throws:

IOException

mergeRegions

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

Throws:

IOException

deleteRegion

public void deleteRegion(RegionInfo regionInfo)
                  throws IOException

Throws:

IOException

deleteRegions

public void deleteRegions(List<RegionInfo> regions)
                   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)

getTableDescriptor

private TableDescriptor getTableDescriptor(TableName tableName)
                                    throws IOException

Throws:

IOException

getRegionServer

static ServerName getRegionServer(Result r,
                                  int replicaId)

Returns the ServerName from catalog table Result where the region is transitioning. It should be the same as MetaTableAccessor.getServerName(Result,int) if the server is at OPEN state.

Parameters:

r - Result to pull the transitioning server name from

Returns:

A ServerName instance or MetaTableAccessor.getServerName(Result,int) if necessary fields not found or empty.

getServerNameColumn

private static byte[] getServerNameColumn(int replicaId)

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

private static byte[] getStateColumn(int replicaId)