public class LoadBalancerUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static long |
recentJobPeriod |
Constructor and Description |
---|
LoadBalancerUtil() |
Modifier and Type | Method and Description |
---|---|
protected static java.util.List<java.lang.String> |
getBlacklist(java.util.Properties properties) |
protected static java.lang.String |
getHostNamePrefix(java.lang.String baseInvocationURL) |
protected static java.util.List<java.lang.String> |
getHostNames(java.util.Properties properties,
java.lang.String hostNamePrefix) |
static java.lang.String |
getMostAvailableMasterURL(java.util.Map<java.lang.String,java.lang.String> overrideMap) |
static java.lang.String |
getMostAvailableMasterURL(java.util.Properties properties) |
static java.lang.String |
getMostAvailableMasterURL(java.lang.String propertiesURL,
java.util.Map<java.lang.String,java.lang.String> overrideMap) |
protected static int |
getRandomValue(int start,
int end) |
protected static java.util.Map<java.lang.String,java.lang.Integer> |
getRecentJobCountMap(java.io.File dir) |
protected static void |
startParallelTasks(java.util.Map<java.lang.String,java.lang.Integer> recentJobMap,
java.util.List<java.lang.String> hostNames,
java.lang.String hostNamePrefix,
java.util.Properties properties,
java.util.List<java.util.concurrent.FutureTask<java.lang.Integer>> futureTasks) |
protected static void |
waitForTurn(java.io.File file,
int hostNameCount) |
public static java.lang.String getMostAvailableMasterURL(java.util.Map<java.lang.String,java.lang.String> overrideMap) throws java.lang.Exception
java.lang.Exception
public static java.lang.String getMostAvailableMasterURL(java.util.Properties properties) throws java.lang.Exception
java.lang.Exception
public static java.lang.String getMostAvailableMasterURL(java.lang.String propertiesURL, java.util.Map<java.lang.String,java.lang.String> overrideMap) throws java.lang.Exception
java.lang.Exception
protected static java.util.List<java.lang.String> getBlacklist(java.util.Properties properties)
protected static java.lang.String getHostNamePrefix(java.lang.String baseInvocationURL)
protected static java.util.List<java.lang.String> getHostNames(java.util.Properties properties, java.lang.String hostNamePrefix)
protected static int getRandomValue(int start, int end)
protected static java.util.Map<java.lang.String,java.lang.Integer> getRecentJobCountMap(java.io.File dir) throws java.lang.Exception
java.lang.Exception
protected static void startParallelTasks(java.util.Map<java.lang.String,java.lang.Integer> recentJobMap, java.util.List<java.lang.String> hostNames, java.lang.String hostNamePrefix, java.util.Properties properties, java.util.List<java.util.concurrent.FutureTask<java.lang.Integer>> futureTasks) throws java.lang.Exception
java.lang.Exception
protected static void waitForTurn(java.io.File file, int hostNameCount) throws java.lang.Exception
java.lang.Exception