Package org.apache.hadoop.hbase.favored

Class TestFavoredNodeAssignmentHelper

java.lang.Object

org.apache.hadoop.hbase.favored.TestFavoredNodeAssignmentHelper

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestFavoredNodeAssignmentHelper
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	MAX_ATTEMPTS
private static String	methodName
private static final org.apache.hadoop.hbase.master.RackManager	rackManager
private static final Map<String,List<org.apache.hadoop.hbase.ServerName>>	rackToServers
private static final 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	setupBeforeAll()
void	setupEach(org.junit.jupiter.api.TestInfo testInfo)
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

servers

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

rackToServers

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

rackManager

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

MAX_ATTEMPTS

private static final int MAX_ATTEMPTS

See Also:

• Constant Field Values

methodName

private static String methodName

Constructor Details

TestFavoredNodeAssignmentHelper

public TestFavoredNodeAssignmentHelper()

Method Details

getRack

private static String getRack(int index)

setupBeforeAll

@BeforeAll
public static void setupBeforeAll()
                           throws Exception

Throws:

Exception

setupEach

@BeforeEach
public void setupEach(org.junit.jupiter.api.TestInfo testInfo)

getServersFromRack

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

testSmallCluster

@Test
public void testSmallCluster()

testPlacePrimaryRSAsRoundRobin

@Test
public void testPlacePrimaryRSAsRoundRobin()

testRoundRobinAssignmentsWithUnevenSizedRacks

@Test
public void testRoundRobinAssignmentsWithUnevenSizedRacks()

testSecondaryAndTertiaryPlacementWithSingleRack

@Test
public void testSecondaryAndTertiaryPlacementWithSingleRack()

testSecondaryAndTertiaryPlacementWithSingleServer

@Test
public void testSecondaryAndTertiaryPlacementWithSingleServer()

testSecondaryAndTertiaryPlacementWithMultipleRacks

@Test
public void testSecondaryAndTertiaryPlacementWithMultipleRacks()

testSecondaryAndTertiaryPlacementWithLessThanTwoServersInRacks

@Test
public void testSecondaryAndTertiaryPlacementWithLessThanTwoServersInRacks()

testSecondaryAndTertiaryPlacementWithMoreThanOneServerInPrimaryRack

@Test
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

@Test
public void testConstrainedPlacement()
                              throws Exception

Throws:

Exception

testGetOneRandomRack

@Test
public void testGetOneRandomRack()
                          throws IOException

Throws:

IOException

testGetRandomServerSingleRack

@Test
public void testGetRandomServerSingleRack()
                                   throws IOException

Throws:

IOException

testGetRandomServerMultiRack

@Test
public void testGetRandomServerMultiRack()
                                  throws IOException

Throws:

IOException

testGetFavoredNodes

@Test
public void testGetFavoredNodes()
                         throws IOException

Throws:

IOException

testGenMissingFavoredNodeOneRack

@Test
public void testGenMissingFavoredNodeOneRack()
                                      throws IOException

Throws:

IOException

testGenMissingFavoredNodeMultiRack

@Test
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)