public class LoadBalancerUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static long |
RECENT_BATCH_AGE |
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 |
getMasterPrefix(java.lang.String baseInvocationURL) |
protected static java.util.List<java.lang.String> |
getMasters(java.lang.String masterPrefix,
java.util.Properties properties) |
static java.lang.String |
getMostAvailableMasterURL(java.util.Properties properties) |
static java.lang.String |
getMostAvailableMasterURL(java.lang.String... overridePropertiesArray) |
static java.lang.String |
getMostAvailableMasterURL(java.lang.String propertiesURL,
java.lang.String[] overridePropertiesArray) |
protected static int |
getRandomValue(int start,
int end) |
protected static int |
getRecentBatchSizesTotal(java.lang.String master) |
protected static void |
startParallelTasks(java.util.List<java.util.concurrent.FutureTask<java.lang.Integer>> futureTasks,
java.util.List<java.lang.String> masters,
java.lang.String masterPrefix,
java.util.Properties properties) |
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... overridePropertiesArray) throws java.lang.Exception
java.lang.Exception
public static java.lang.String getMostAvailableMasterURL(java.lang.String propertiesURL, java.lang.String[] overridePropertiesArray) 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 getMasterPrefix(java.lang.String baseInvocationURL)
protected static java.util.List<java.lang.String> getMasters(java.lang.String masterPrefix, java.util.Properties properties)
protected static int getRandomValue(int start, int end)
protected static int getRecentBatchSizesTotal(java.lang.String master) throws java.lang.Exception
java.lang.Exception
protected static void startParallelTasks(java.util.List<java.util.concurrent.FutureTask<java.lang.Integer>> futureTasks, java.util.List<java.lang.String> masters, java.lang.String masterPrefix, java.util.Properties properties) throws java.lang.Exception
java.lang.Exception