Modifier and Type | Field and Description |
---|---|
static String |
ALLOCATION_FILE |
protected static String |
ALLOW_UNDECLARED_POOLS
Whether pools can be created that were not specified in the FS configuration file
|
static String |
ASSIGN_MULTIPLE
Whether to assign multiple containers in one check-in.
|
protected static String |
CONTINUOUS_SCHEDULING_ENABLED
Enable continuous scheduling or not.
|
protected static String |
CONTINUOUS_SCHEDULING_SLEEP_MS
Sleep time of each pass in continuous scheduling (5ms in default)
|
protected static String |
DEFAULT_ALLOCATION_FILE |
protected static boolean |
DEFAULT_ALLOW_UNDECLARED_POOLS |
protected static boolean |
DEFAULT_ASSIGN_MULTIPLE |
protected static boolean |
DEFAULT_CONTINUOUS_SCHEDULING_ENABLED |
protected static int |
DEFAULT_CONTINUOUS_SCHEDULING_SLEEP_MS |
static boolean |
DEFAULT_EVENT_LOG_ENABLED |
protected static long |
DEFAULT_LOCALITY_DELAY_NODE_MS |
protected static long |
DEFAULT_LOCALITY_DELAY_RACK_MS |
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 |
protected static float |
DEFAULT_PREEMPTION_THRESHOLD |
static int |
DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_MB |
static int |
DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES |
static float |
DEFAULT_RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE |
protected static boolean |
DEFAULT_SIZE_BASED_WEIGHT |
static int |
DEFAULT_UPDATE_INTERVAL_MS |
protected static boolean |
DEFAULT_USER_AS_DEFAULT_QUEUE |
protected static int |
DEFAULT_WAIT_TIME_BEFORE_KILL |
static String |
DYNAMIC_MAX_ASSIGN
Maximum number of containers to assign on each check-in.
|
protected static String |
EVENT_LOG_DIR |
static String |
EVENT_LOG_ENABLED
Whether to enable the Fair Scheduler event log
|
protected static String |
LOCALITY_DELAY_NODE_MS
Delay for node locality.
|
protected static String |
LOCALITY_DELAY_RACK_MS
Delay for rack locality.
|
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
Specify exact number of containers to assign on each heartbeat, if dynamic
max assign is turned off.
|
protected static String |
PREEMPTION
Whether preemption is enabled.
|
protected static String |
PREEMPTION_INTERVAL |
protected static String |
PREEMPTION_THRESHOLD |
static String |
RESERVABLE_NODES
Ratio of nodes available for an app to make an reservation on.
|
static float |
RESERVABLE_NODES_DEFAULT |
static String |
RM_SCHEDULER_INCREMENT_ALLOCATION_MB
Increment request grant-able by the RM scheduler.
|
static String |
RM_SCHEDULER_INCREMENT_ALLOCATION_VCORES |
static String |
RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE
Threshold for container size for making a container reservation as a
multiple of increment allocation.
|
protected static String |
SIZE_BASED_WEIGHT
Whether to give more weight to apps requiring many resources.
|
static String |
UPDATE_INTERVAL_MS
The update interval for calculating resources in FairScheduler .
|
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() |
FairSchedulerConfiguration(org.apache.hadoop.conf.Configuration conf) |
addDefaultResource, addDeprecation, addDeprecation, addDeprecation, addDeprecation, addDeprecations, addResource, addResource, addResource, addResource, addResource, addResource, clear, dumpConfiguration, dumpDeprecatedKeys, get, get, getBoolean, getClass, getClass, getClassByName, getClassByNameOrNull, getClasses, getClassLoader, getConfResourceAsInputStream, getConfResourceAsReader, getDouble, getEnum, getFile, getFinalParameters, getFloat, getInstances, getInt, getInts, getLocalPath, getLong, getLongBytes, getPassword, getPasswordFromConfig, getPasswordFromCredentialProviders, getPattern, getPropertySources, getProps, getPropsWithPrefix, getRange, getRaw, getResource, getSocketAddr, getSocketAddr, getStringCollection, getStrings, getStrings, getTimeDuration, getTimeDurations, getTrimmed, getTrimmed, getTrimmedStringCollection, getTrimmedStrings, getTrimmedStrings, getValByRegex, hasWarnedDeprecation, isDeprecated, iterator, main, onlyKeyExists, readFields, reloadConfiguration, reloadExistingConfigurations, set, set, setAllowNullValueProperties, setBoolean, setBooleanIfUnset, setClass, setClassLoader, setDeprecatedProperties, setDouble, setEnum, setFloat, setIfUnset, setInt, setLong, setPattern, setQuietMode, setSocketAddr, setStrings, setTimeDuration, size, toString, unset, updateConnectAddr, 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
public static final String RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE
public static final float DEFAULT_RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE
public static final String ALLOCATION_FILE
protected static final String DEFAULT_ALLOCATION_FILE
public static final String EVENT_LOG_ENABLED
public static final boolean DEFAULT_EVENT_LOG_ENABLED
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 LOCALITY_DELAY_NODE_MS
protected static final long DEFAULT_LOCALITY_DELAY_NODE_MS
protected static final String LOCALITY_DELAY_RACK_MS
protected static final long DEFAULT_LOCALITY_DELAY_RACK_MS
protected static final String CONTINUOUS_SCHEDULING_ENABLED
protected static final boolean DEFAULT_CONTINUOUS_SCHEDULING_ENABLED
protected static final String CONTINUOUS_SCHEDULING_SLEEP_MS
protected static final int DEFAULT_CONTINUOUS_SCHEDULING_SLEEP_MS
protected static final String PREEMPTION
protected static final boolean DEFAULT_PREEMPTION
protected static final String PREEMPTION_THRESHOLD
protected static final float DEFAULT_PREEMPTION_THRESHOLD
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
public 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
public static final String DYNAMIC_MAX_ASSIGN
protected static final String MAX_ASSIGN
protected static final int DEFAULT_MAX_ASSIGN
public static final String UPDATE_INTERVAL_MS
public static final int DEFAULT_UPDATE_INTERVAL_MS
public static final String RESERVABLE_NODES
public static final float RESERVABLE_NODES_DEFAULT
public FairSchedulerConfiguration()
public FairSchedulerConfiguration(org.apache.hadoop.conf.Configuration conf)
public org.apache.hadoop.yarn.api.records.Resource getMinimumAllocation()
public org.apache.hadoop.yarn.api.records.Resource getMaximumAllocation()
public org.apache.hadoop.yarn.api.records.Resource getIncrementAllocation()
public float getReservationThresholdIncrementMultiple()
public float getLocalityThresholdNode()
public float getLocalityThresholdRack()
public boolean isContinuousSchedulingEnabled()
public int getContinuousSchedulingSleepMs()
public long getLocalityDelayNodeMs()
public long getLocalityDelayRackMs()
public boolean getPreemptionEnabled()
public float getPreemptionUtilizationThreshold()
public boolean getAssignMultiple()
public boolean isMaxAssignDynamic()
public int getMaxAssign()
public boolean getSizeBasedWeight()
public boolean isEventLogEnabled()
public String getEventlogDir()
public int getPreemptionInterval()
public int getWaitTimeBeforeKill()
public boolean getUsePortForNodeName()
public float getReservableNodes()
public static org.apache.hadoop.yarn.api.records.Resource parseResourceConfigValue(String val) throws AllocationConfigurationException
AllocationConfigurationException
public long getUpdateInterval()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.