public abstract class ReservationSchedulerConfiguration
extends org.apache.hadoop.conf.Configuration
Modifier and Type | Field and Description |
---|---|
static float |
DEFAULT_CAPACITY_OVER_TIME_MULTIPLIER |
static String |
DEFAULT_RESERVATION_ADMISSION_POLICY |
static String |
DEFAULT_RESERVATION_AGENT_NAME |
static long |
DEFAULT_RESERVATION_ENFORCEMENT_WINDOW |
static boolean |
DEFAULT_RESERVATION_MOVE_ON_EXPIRY |
static String |
DEFAULT_RESERVATION_PLANNER_NAME |
static long |
DEFAULT_RESERVATION_WINDOW |
static boolean |
DEFAULT_SHOW_RESERVATIONS_AS_QUEUES |
Constructor and Description |
---|
ReservationSchedulerConfiguration() |
ReservationSchedulerConfiguration(org.apache.hadoop.conf.Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
float |
getAverageCapacity(String queue)
Gets the average allowed capacity which will aggregated over the
getReservationWindow(java.lang.String) by the
the SharingPolicy to check aggregate used capacity |
long |
getEnforcementWindow(String queue)
Gets the time in milliseconds for which the
Planner will verify
the Plan s satisfy the constraints |
float |
getInstantaneousMaxCapacity(String queue)
Gets the maximum capacity at any time that the
SharingPolicy allows |
boolean |
getMoveOnExpiry(String queue)
Gets whether the applications should be killed or moved to the parent queue
when the
ReservationDefinition expires |
String |
getReplanner(String queue)
Gets the name of the
Planner class associated with the
queue |
abstract Map<org.apache.hadoop.yarn.api.records.ReservationACL,org.apache.hadoop.security.authorize.AccessControlList> |
getReservationAcls(String queue)
Gets a map containing the
AccessControlList of users for each
ReservationACL acl on thee specified queue. |
String |
getReservationAdmissionPolicy(String queue)
Gets the name of the
SharingPolicy class associated with the queue |
String |
getReservationAgent(String queue)
Gets the name of the
ReservationAgent class associated with the
queue |
long |
getReservationWindow(String queue)
Gets the length of time in milliseconds for which the
SharingPolicy
checks for validity |
boolean |
getShowReservationAsQueues(String queuePath)
Checks whether the reservation queues be hidden or visible
|
abstract boolean |
isReservable(String queue)
Checks if the queue participates in reservation based scheduling
|
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
@InterfaceAudience.Private public static final long DEFAULT_RESERVATION_WINDOW
@InterfaceAudience.Private public static final String DEFAULT_RESERVATION_ADMISSION_POLICY
@InterfaceAudience.Private public static final String DEFAULT_RESERVATION_AGENT_NAME
@InterfaceAudience.Private public static final String DEFAULT_RESERVATION_PLANNER_NAME
@InterfaceAudience.Private public static final boolean DEFAULT_RESERVATION_MOVE_ON_EXPIRY
@InterfaceAudience.Private public static final long DEFAULT_RESERVATION_ENFORCEMENT_WINDOW
@InterfaceAudience.Private public static final boolean DEFAULT_SHOW_RESERVATIONS_AS_QUEUES
@InterfaceAudience.Private public static final float DEFAULT_CAPACITY_OVER_TIME_MULTIPLIER
public ReservationSchedulerConfiguration()
public ReservationSchedulerConfiguration(org.apache.hadoop.conf.Configuration configuration)
public abstract boolean isReservable(String queue)
queue
- name of the queuepublic abstract Map<org.apache.hadoop.yarn.api.records.ReservationACL,org.apache.hadoop.security.authorize.AccessControlList> getReservationAcls(String queue)
AccessControlList
of users for each
ReservationACL
acl on thee specified queue.queue
- the queue with which to check a user's permissions.ReservationACL
to AccessControlList
which contains a list of users that have the specified permission level.public long getReservationWindow(String queue)
SharingPolicy
checks for validityqueue
- name of the queueSharingPolicy
public float getAverageCapacity(String queue)
getReservationWindow(java.lang.String)
by the
the SharingPolicy
to check aggregate used capacityqueue
- name of the queueSharingPolicy
public float getInstantaneousMaxCapacity(String queue)
SharingPolicy
allowsqueue
- name of the queuepublic String getReservationAdmissionPolicy(String queue)
SharingPolicy
class associated with the queuequeue
- name of the queueSharingPolicy
public String getReservationAgent(String queue)
ReservationAgent
class associated with the
queuequeue
- name of the queueReservationAgent
public boolean getShowReservationAsQueues(String queuePath)
queuePath
- name of the queuepublic String getReplanner(String queue)
Planner
class associated with the
queuequeue
- name of the queuePlanner
public boolean getMoveOnExpiry(String queue)
ReservationDefinition
expiresqueue
- name of the queueCopyright © 2017 Apache Software Foundation. All Rights Reserved.