Package org.apache.hadoop.hbase.favored

Class TestFavoredNodeAssignmentHelper

java.lang.Object

org.apache.hadoop.hbase.favored.TestFavoredNodeAssignmentHelper

public class TestFavoredNodeAssignmentHelper
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final int	MAX_ATTEMPTS
org.junit.rules.TestName	name
private static org.apache.hadoop.hbase.master.RackManager	rackManager
private static Map<String,List<org.apache.hadoop.hbase.ServerName>>	rackToServers
private static List<org.apache.hadoop.hbase.ServerName>	servers

Constructor Summary

Constructors

Constructor	Description
TestFavoredNodeAssignmentHelper()

Method Summary

Modifier and Type	Method	Description
private void	checkDuplicateFN(List<org.apache.hadoop.hbase.ServerName> fnList)
private void	checkDuplicateFN(List<org.apache.hadoop.hbase.ServerName> fnList, org.apache.hadoop.hbase.ServerName genFN)
private void	checkFNRacks(List<org.apache.hadoop.hbase.ServerName> fnList)
private void	checkFNRacks(List<org.apache.hadoop.hbase.ServerName> fnList, org.apache.hadoop.hbase.ServerName genFN)
private void	checkNumRegions(int firstRackSize, int secondRackSize, int thirdRackSize, int regionsOnRack1, int regionsOnRack2, int regionsOnRack3)
private static String	getRack(int index)
private static List<org.apache.hadoop.hbase.ServerName>	getServersFromRack(Map<String,Integer> rackToServerCount)
private void	primaryRSPlacement(int regionCount, Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> primaryRSMap, int firstRackSize, int secondRackSize, int thirdRackSize)
private String	printProportions(int firstRackSize, int secondRackSize, int thirdRackSize, int regionsOnRack1, int regionsOnRack2, int regionsOnRack3)
private org.apache.hadoop.hbase.util.Triple<Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName>,org.apache.hadoop.hbase.favored.FavoredNodeAssignmentHelper,List<org.apache.hadoop.hbase.client.RegionInfo>>	secondaryAndTertiaryRSPlacementHelper(int regionCount, Map<String,Integer> rackToServerCount)
static void	setupBeforeClass()
void	testConstrainedPlacement()
void	testGenMissingFavoredNodeMultiRack()
void	testGenMissingFavoredNodeOneRack()
void	testGetFavoredNodes()
void	testGetOneRandomRack()
void	testGetRandomServerMultiRack()
void	testGetRandomServerSingleRack()
void	testPlacePrimaryRSAsRoundRobin()
void	testRoundRobinAssignmentsWithUnevenSizedRacks()
void	testSecondaryAndTertiaryPlacementWithLessThanTwoServersInRacks()
void	testSecondaryAndTertiaryPlacementWithMoreThanOneServerInPrimaryRack()
void	testSecondaryAndTertiaryPlacementWithMultipleRacks()
void	testSecondaryAndTertiaryPlacementWithSingleRack()
void	testSecondaryAndTertiaryPlacementWithSingleServer()
void	testSmallCluster()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

servers

private static List<org.apache.hadoop.hbase.ServerName> servers

rackToServers

private static Map<String,List<org.apache.hadoop.hbase.ServerName>> rackToServers

rackManager

private static org.apache.hadoop.hbase.master.RackManager rackManager

MAX_ATTEMPTS

private static final int MAX_ATTEMPTS

See Also:

• Constant Field Values

name

public org.junit.rules.TestName name

Constructor Details

TestFavoredNodeAssignmentHelper

public TestFavoredNodeAssignmentHelper()

Method Details

getRack

private static String getRack(int index)

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

getServersFromRack

private static List<org.apache.hadoop.hbase.ServerName> getServersFromRack(Map<String,Integer> rackToServerCount)

testSmallCluster

public void testSmallCluster()

testPlacePrimaryRSAsRoundRobin

public void testPlacePrimaryRSAsRoundRobin()

testRoundRobinAssignmentsWithUnevenSizedRacks

public void testRoundRobinAssignmentsWithUnevenSizedRacks()

testSecondaryAndTertiaryPlacementWithSingleRack

public void testSecondaryAndTertiaryPlacementWithSingleRack()

testSecondaryAndTertiaryPlacementWithSingleServer

public void testSecondaryAndTertiaryPlacementWithSingleServer()

testSecondaryAndTertiaryPlacementWithMultipleRacks

public void testSecondaryAndTertiaryPlacementWithMultipleRacks()

testSecondaryAndTertiaryPlacementWithLessThanTwoServersInRacks

public void testSecondaryAndTertiaryPlacementWithLessThanTwoServersInRacks()

testSecondaryAndTertiaryPlacementWithMoreThanOneServerInPrimaryRack

public void testSecondaryAndTertiaryPlacementWithMoreThanOneServerInPrimaryRack()

secondaryAndTertiaryRSPlacementHelper

private org.apache.hadoop.hbase.util.Triple<Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName>,org.apache.hadoop.hbase.favored.FavoredNodeAssignmentHelper,List<org.apache.hadoop.hbase.client.RegionInfo>> secondaryAndTertiaryRSPlacementHelper(int regionCount,
 Map<String,Integer> rackToServerCount)

primaryRSPlacement

private void primaryRSPlacement(int regionCount,
 Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> primaryRSMap,
 int firstRackSize,
 int secondRackSize,
 int thirdRackSize)

checkNumRegions

private void checkNumRegions(int firstRackSize,
 int secondRackSize,
 int thirdRackSize,
 int regionsOnRack1,
 int regionsOnRack2,
 int regionsOnRack3)

printProportions

private String printProportions(int firstRackSize,
 int secondRackSize,
 int thirdRackSize,
 int regionsOnRack1,
 int regionsOnRack2,
 int regionsOnRack3)

testConstrainedPlacement

public void testConstrainedPlacement()
                              throws Exception

Throws:

Exception

testGetOneRandomRack

public void testGetOneRandomRack()
                          throws IOException

Throws:

IOException

testGetRandomServerSingleRack

public void testGetRandomServerSingleRack()
                                   throws IOException

Throws:

IOException

testGetRandomServerMultiRack

public void testGetRandomServerMultiRack()
                                  throws IOException

Throws:

IOException

testGetFavoredNodes

public void testGetFavoredNodes()
                         throws IOException

Throws:

IOException

testGenMissingFavoredNodeOneRack

public void testGenMissingFavoredNodeOneRack()
                                      throws IOException

Throws:

IOException

testGenMissingFavoredNodeMultiRack

public void testGenMissingFavoredNodeMultiRack()
                                        throws IOException

Throws:

IOException

checkDuplicateFN

private void checkDuplicateFN(List<org.apache.hadoop.hbase.ServerName> fnList,
 org.apache.hadoop.hbase.ServerName genFN)

checkDuplicateFN

private void checkDuplicateFN(List<org.apache.hadoop.hbase.ServerName> fnList)

checkFNRacks

private void checkFNRacks(List<org.apache.hadoop.hbase.ServerName> fnList,
 org.apache.hadoop.hbase.ServerName genFN)

checkFNRacks

private void checkFNRacks(List<org.apache.hadoop.hbase.ServerName> fnList)