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 and Description
static HBaseClassTestRule	CLASS_RULE
private static 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 and Description
TestFavoredNodeAssignmentHelper()

Method Summary

Modifier and Type	Method and 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 regionCount, int firstRackSize, int secondRackSize, int thirdRackSize, int regionsOnRack1, int regionsOnRack2, int regionsOnRack3, Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignmentMap)
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 Detail

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 Detail

TestFavoredNodeAssignmentHelper

public TestFavoredNodeAssignmentHelper()

Method Detail

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 regionCount,
                             int firstRackSize,
                             int secondRackSize,
                             int thirdRackSize,
                             int regionsOnRack1,
                             int regionsOnRack2,
                             int regionsOnRack3,
                             Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignmentMap)

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)