Package org.apache.hadoop.hbase.favored

Class FavoredNodesManager

java.lang.Object

org.apache.hadoop.hbase.favored.FavoredNodesManager

@Private
public class FavoredNodesManager
extends Object

FavoredNodesManager is responsible for maintaining favored nodes info in internal cache and META table. Its the centralized store for all favored nodes information. All reads and updates should be done through this class. There should only be one instance of FavoredNodesManager in Master. FavoredNodesPlan and favored node information from SnapshotOfRegionAssignmentFromMeta should not be used outside this class (except for tools that only read or fortest cases). All other classes including Favored balancers and FavoredNodeAssignmentHelper should use FavoredNodesManager for any read/write/deletes to favored nodes.

Field Summary

Fields

Modifier and Type	Field	Description
private int	datanodeDataTransferPort	Datanode port to be used for Favored Nodes.
private final FavoredNodesPlan	globalFavoredNodesAssignmentPlan
private static final org.slf4j.Logger	LOG
private final MasterServices	masterServices
private final Map<ServerName,List<RegionInfo>>	primaryRSToRegionMap
private final RackManager	rackManager
private final Map<ServerName,List<RegionInfo>>	secondaryRSToRegionMap
private final Map<ServerName,List<RegionInfo>>	teritiaryRSToRegionMap

Constructor Summary

Constructors

Constructor	Description
FavoredNodesManager(MasterServices masterServices)

Method Summary

Modifier and Type	Method	Description
private void	addToReplicaLoad(RegionInfo hri, List<ServerName> servers)
void	deleteFavoredNodesForRegion(RegionInfo regionInfo)
void	deleteFavoredNodesForRegions(Collection<RegionInfo> regionInfoList)
static Set<RegionInfo>	filterNonFNApplicableRegions(Collection<RegionInfo> regions)	Filter and return regions for which favored nodes is not applicable.
int	getDataNodePort()
List<ServerName>	getFavoredNodes(RegionInfo regionInfo)
List<ServerName>	getFavoredNodesWithDNPort(RegionInfo regionInfo)
RackManager	getRackManager()
Set<RegionInfo>	getRegionsOfFavoredNode(ServerName serverName)
Map<ServerName,List<Integer>>	getReplicaLoad(List<ServerName> servers)
void	initialize(SnapshotOfRegionAssignmentFromMeta snapshot)
static boolean	isFavoredNodeApplicable(RegionInfo regionInfo)
void	updateFavoredNodes(Map<RegionInfo,List<ServerName>> regionFNMap)

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

globalFavoredNodesAssignmentPlan

private final FavoredNodesPlan globalFavoredNodesAssignmentPlan

primaryRSToRegionMap

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

secondaryRSToRegionMap

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

teritiaryRSToRegionMap

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

masterServices

private final MasterServices masterServices

rackManager

private final RackManager rackManager

datanodeDataTransferPort

private int datanodeDataTransferPort

Datanode port to be used for Favored Nodes.

Constructor Details

FavoredNodesManager

public FavoredNodesManager(MasterServices masterServices)

Method Details

initialize

public void initialize(SnapshotOfRegionAssignmentFromMeta snapshot)

getDataNodePort

public int getDataNodePort()

getFavoredNodes

public List<ServerName> getFavoredNodes(RegionInfo regionInfo)

isFavoredNodeApplicable

public static boolean isFavoredNodeApplicable(RegionInfo regionInfo)

filterNonFNApplicableRegions

public static Set<RegionInfo> filterNonFNApplicableRegions(Collection<RegionInfo> regions)

Filter and return regions for which favored nodes is not applicable.

Returns:

set of regions for which favored nodes is not applicable

getFavoredNodesWithDNPort

public List<ServerName> getFavoredNodesWithDNPort(RegionInfo regionInfo)

updateFavoredNodes

public void updateFavoredNodes(Map<RegionInfo,List<ServerName>> regionFNMap)
                        throws IOException

Throws:

IOException

addToReplicaLoad

private void addToReplicaLoad(RegionInfo hri,
 List<ServerName> servers)

getReplicaLoad

public Map<ServerName,List<Integer>> getReplicaLoad(List<ServerName> servers)

deleteFavoredNodesForRegion

public void deleteFavoredNodesForRegion(RegionInfo regionInfo)

deleteFavoredNodesForRegions

public void deleteFavoredNodesForRegions(Collection<RegionInfo> regionInfoList)

getRegionsOfFavoredNode

public Set<RegionInfo> getRegionsOfFavoredNode(ServerName serverName)

getRackManager

public RackManager getRackManager()