org.apache.hadoop.hbase.master

Class SnapshotOfRegionAssignmentFromMeta

java.lang.Object

org.apache.hadoop.hbase.master.SnapshotOfRegionAssignmentFromMeta

@InterfaceAudience.Private
public class SnapshotOfRegionAssignmentFromMeta
extends Object

Used internally for reading meta and constructing datastructures that are then queried, for things like regions to regionservers, table to regions, etc. It also records the favored nodes mapping for regions.

Field Summary

Fields

Modifier and Type	Field and Description
private Connection	connection
private Map<ServerName,List<RegionInfo>>	currentRSToRegionMap the regionServer to region map
private Set<TableName>	disabledTables
private boolean	excludeOfflinedSplitParents
private FavoredNodesPlan	existingAssignmentPlan the existing assignment plan in the hbase:meta region
private static org.slf4j.Logger	LOG
private Map<ServerName,List<RegionInfo>>	primaryRSToRegionMap
private Map<String,RegionInfo>	regionNameToRegionInfoMap the region name to region info map
private Map<RegionInfo,ServerName>	regionToRegionServerMap the region to region server map
private Map<ServerName,List<RegionInfo>>	secondaryRSToRegionMap
private Map<TableName,List<RegionInfo>>	tableToRegionMap the table name to region map
private Map<ServerName,List<RegionInfo>>	teritiaryRSToRegionMap

Constructor Summary

Constructors

Constructor and Description
SnapshotOfRegionAssignmentFromMeta(Connection connection)
SnapshotOfRegionAssignmentFromMeta(Connection connection, Set<TableName> disabledTables, boolean excludeOfflinedSplitParents)

Method Summary

Modifier and Type	Method and Description
private void	addAssignment(RegionInfo regionInfo, ServerName server)
private void	addPrimaryAssignment(RegionInfo regionInfo, ServerName server)
private void	addRegion(RegionInfo regionInfo)
private void	addSecondaryAssignment(RegionInfo regionInfo, ServerName server)
private void	addTeritiaryAssignment(RegionInfo regionInfo, ServerName server)
FavoredNodesPlan	getExistingAssignmentPlan() Get the favored nodes plan
Map<ServerName,List<RegionInfo>>	getPrimaryToRegionInfoMap()
Map<String,RegionInfo>	getRegionNameToRegionInfoMap() Get the regioninfo for a region
Map<ServerName,List<RegionInfo>>	getRegionServerToRegionMap() Get regionserver to region map
Map<RegionInfo,ServerName>	getRegionToRegionServerMap() Get region to region server map
Map<ServerName,List<RegionInfo>>	getSecondaryToRegionInfoMap()
Set<TableName>	getTableSet() Get the table set
Map<TableName,List<RegionInfo>>	getTableToRegionMap() Get regions for tables
Map<ServerName,List<RegionInfo>>	getTertiaryToRegionInfoMap()
void	initialize() Initialize the region assignment snapshot by scanning the hbase:meta table

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

connection

private final Connection connection

tableToRegionMap

private final Map<TableName,List<RegionInfo>> tableToRegionMap

the table name to region map

regionToRegionServerMap

private Map<RegionInfo,ServerName> regionToRegionServerMap

the region to region server map

regionNameToRegionInfoMap

private final Map<String,RegionInfo> regionNameToRegionInfoMap

the region name to region info map

currentRSToRegionMap

private final Map<ServerName,List<RegionInfo>> currentRSToRegionMap

the regionServer to region map

secondaryRSToRegionMap

private final Map<ServerName,List<RegionInfo>> secondaryRSToRegionMap

teritiaryRSToRegionMap

private final Map<ServerName,List<RegionInfo>> teritiaryRSToRegionMap

primaryRSToRegionMap

private final Map<ServerName,List<RegionInfo>> primaryRSToRegionMap

existingAssignmentPlan

private final FavoredNodesPlan existingAssignmentPlan

the existing assignment plan in the hbase:meta region

disabledTables

private final Set<TableName> disabledTables

excludeOfflinedSplitParents

private final boolean excludeOfflinedSplitParents

Constructor Detail

SnapshotOfRegionAssignmentFromMeta

public SnapshotOfRegionAssignmentFromMeta(Connection connection)

SnapshotOfRegionAssignmentFromMeta

public SnapshotOfRegionAssignmentFromMeta(Connection connection,
                                          Set<TableName> disabledTables,
                                          boolean excludeOfflinedSplitParents)

Method Detail

initialize

public void initialize()
                throws IOException

Initialize the region assignment snapshot by scanning the hbase:meta table

Throws:

IOException

addRegion

private void addRegion(RegionInfo regionInfo)

addAssignment

private void addAssignment(RegionInfo regionInfo,
                           ServerName server)

addPrimaryAssignment

private void addPrimaryAssignment(RegionInfo regionInfo,
                                  ServerName server)

addSecondaryAssignment

private void addSecondaryAssignment(RegionInfo regionInfo,
                                    ServerName server)

addTeritiaryAssignment

private void addTeritiaryAssignment(RegionInfo regionInfo,
                                    ServerName server)

getRegionNameToRegionInfoMap

public Map<String,RegionInfo> getRegionNameToRegionInfoMap()

Get the regioninfo for a region

Returns:

the regioninfo

getTableToRegionMap

public Map<TableName,List<RegionInfo>> getTableToRegionMap()

Get regions for tables

Returns:

a mapping from table to regions

getRegionToRegionServerMap

public Map<RegionInfo,ServerName> getRegionToRegionServerMap()

Get region to region server map

Returns:

region to region server map

getRegionServerToRegionMap

public Map<ServerName,List<RegionInfo>> getRegionServerToRegionMap()

Get regionserver to region map

Returns:

regionserver to region map

getExistingAssignmentPlan

public FavoredNodesPlan getExistingAssignmentPlan()

Get the favored nodes plan

Returns:

the existing favored nodes plan

getTableSet

public Set<TableName> getTableSet()

Get the table set

Returns:

the table set

getSecondaryToRegionInfoMap

public Map<ServerName,List<RegionInfo>> getSecondaryToRegionInfoMap()

getTertiaryToRegionInfoMap

public Map<ServerName,List<RegionInfo>> getTertiaryToRegionInfoMap()

getPrimaryToRegionInfoMap

public Map<ServerName,List<RegionInfo>> getPrimaryToRegionInfoMap()