@InterfaceAudience.Private @InterfaceStability.Evolving public class FairSchedulerConfiguration extends Configuration
Configuration.IntegerRanges
Modifier and Type | Field and Description |
---|---|
protected static String |
ALLOCATION_FILE |
protected static String |
ALLOW_UNDECLARED_POOLS
Whether pools can be created that were not specified in the FS configuration file
|
protected static String |
ASSIGN_MULTIPLE
Whether to assign multiple containers in one check-in.
|
protected static String |
DEFAULT_ALLOCATION_FILE |
protected static boolean |
DEFAULT_ALLOW_UNDECLARED_POOLS |
protected static boolean |
DEFAULT_ASSIGN_MULTIPLE |
protected static float |
DEFAULT_LOCALITY_THRESHOLD |
protected static float |
DEFAULT_LOCALITY_THRESHOLD_NODE |
protected static float |
DEFAULT_LOCALITY_THRESHOLD_RACK |
protected static int |
DEFAULT_MAX_ASSIGN |
protected static boolean |
DEFAULT_PREEMPTION |
protected static int |
DEFAULT_PREEMPTION_INTERVAL |
static int |
DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_MB |
static int |
DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES |
protected static boolean |
DEFAULT_SIZE_BASED_WEIGHT |
protected static boolean |
DEFAULT_USER_AS_DEFAULT_QUEUE |
protected static int |
DEFAULT_WAIT_TIME_BEFORE_KILL |
protected static String |
EVENT_LOG_DIR |
protected static String |
LOCALITY_THRESHOLD_NODE
Cluster threshold for node locality.
|
protected static String |
LOCALITY_THRESHOLD_RACK
Cluster threshold for rack locality.
|
static org.apache.commons.logging.Log |
LOG |
protected static String |
MAX_ASSIGN
Maximum number of containers to assign on each check-in.
|
protected static String |
PREEMPTION
Whether preemption is enabled.
|
protected static String |
PREEMPTION_INTERVAL |
static String |
RM_SCHEDULER_INCREMENT_ALLOCATION_MB
Increment request grant-able by the RM scheduler.
|
static String |
RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES |
protected static String |
SIZE_BASED_WEIGHT
Whether to give more weight to apps requiring many resources.
|
protected static String |
USER_AS_DEFAULT_QUEUE
Whether to use the user name as the queue name (instead of "default") if
the request does not specify a queue.
|
protected static String |
WAIT_TIME_BEFORE_KILL |
Constructor and Description |
---|
FairSchedulerConfiguration(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
File |
getAllocationFile()
Path to XML file containing allocations.
|
boolean |
getAllowUndeclaredPools() |
boolean |
getAssignMultiple() |
String |
getEventlogDir() |
Resource |
getIncrementAllocation() |
float |
getLocalityThresholdNode() |
float |
getLocalityThresholdRack() |
int |
getMaxAssign() |
Resource |
getMaximumAllocation() |
Resource |
getMinimumAllocation() |
boolean |
getPreemptionEnabled() |
int |
getPreemptionInterval() |
boolean |
getSizeBasedWeight() |
boolean |
getUsePortForNodeName() |
boolean |
getUserAsDefaultQueue() |
int |
getWaitTimeBeforeKill() |
static Resource |
parseResourceConfigValue(String val)
Parses a resource config value of a form like "1024", "1024 mb",
or "1024 mb, 3 vcores".
|
addDefaultResource, addDeprecation, addDeprecation, addDeprecation, addDeprecation, addResource, addResource, addResource, addResource, addResource, clear, dumpConfiguration, dumpDeprecatedKeys, get, get, getBoolean, getClass, getClass, getClassByName, getClassByNameOrNull, getClasses, getClassLoader, getConfResourceAsInputStream, getConfResourceAsReader, getDouble, getEnum, getFile, getFloat, getInstances, getInt, getInts, getLocalPath, getLong, getLongBytes, getPattern, getPropertySources, getProps, getRange, getRaw, getResource, getSocketAddr, getStringCollection, getStrings, getStrings, getTimeDuration, getTrimmed, getTrimmed, getTrimmedStringCollection, getTrimmedStrings, getTrimmedStrings, getValByRegex, isDeprecated, iterator, main, readFields, reloadConfiguration, set, set, setBoolean, setBooleanIfUnset, setClass, setClassLoader, setDouble, setEnum, setFloat, setIfUnset, setInt, setLong, setPattern, setQuietMode, setSocketAddr, setStrings, setTimeDuration, size, toString, unset, updateConnectAddr, write, writeXml, writeXml
public static final org.apache.commons.logging.Log LOG
public static final String RM_SCHEDULER_INCREMENT_ALLOCATION_MB
public static final int DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_MB
public static final String RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES
public static final int DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES
protected static final String ALLOCATION_FILE
protected static final String DEFAULT_ALLOCATION_FILE
protected static final String EVENT_LOG_DIR
protected static final String ALLOW_UNDECLARED_POOLS
protected static final boolean DEFAULT_ALLOW_UNDECLARED_POOLS
protected static final String USER_AS_DEFAULT_QUEUE
protected static final boolean DEFAULT_USER_AS_DEFAULT_QUEUE
protected static final float DEFAULT_LOCALITY_THRESHOLD
protected static final String LOCALITY_THRESHOLD_NODE
protected static final float DEFAULT_LOCALITY_THRESHOLD_NODE
protected static final String LOCALITY_THRESHOLD_RACK
protected static final float DEFAULT_LOCALITY_THRESHOLD_RACK
protected static final String PREEMPTION
protected static final boolean DEFAULT_PREEMPTION
protected static final String PREEMPTION_INTERVAL
protected static final int DEFAULT_PREEMPTION_INTERVAL
protected static final String WAIT_TIME_BEFORE_KILL
protected static final int DEFAULT_WAIT_TIME_BEFORE_KILL
protected static final String ASSIGN_MULTIPLE
protected static final boolean DEFAULT_ASSIGN_MULTIPLE
protected static final String SIZE_BASED_WEIGHT
protected static final boolean DEFAULT_SIZE_BASED_WEIGHT
protected static final String MAX_ASSIGN
protected static final int DEFAULT_MAX_ASSIGN
public FairSchedulerConfiguration(Configuration conf)
public Resource getMinimumAllocation()
public Resource getMaximumAllocation()
public Resource getIncrementAllocation()
public boolean getAllowUndeclaredPools()
public boolean getUserAsDefaultQueue()
public float getLocalityThresholdNode()
public float getLocalityThresholdRack()
public boolean getPreemptionEnabled()
public boolean getAssignMultiple()
public int getMaxAssign()
public boolean getSizeBasedWeight()
public File getAllocationFile()
public String getEventlogDir()
public int getPreemptionInterval()
public int getWaitTimeBeforeKill()
public boolean getUsePortForNodeName()
public static Resource parseResourceConfigValue(String val) throws AllocationConfigurationException
AllocationConfigurationException
Copyright © 2013 Apache Software Foundation. All rights reserved.