@InterfaceAudience.Public @InterfaceStability.Stable public abstract class QueueInfo extends Object
It includes information such as:
QueueState
of the queue.QueueConfigurations
of the queue.Constructor and Description |
---|
QueueInfo() |
Modifier and Type | Method and Description |
---|---|
abstract Set<String> |
getAccessibleNodeLabels()
Get the
accessible node labels of the queue. |
abstract List<ApplicationReport> |
getApplications()
Get the running applications of the queue.
|
abstract float |
getCapacity()
Get the configured capacity of the queue.
|
abstract List<QueueInfo> |
getChildQueues()
Get the child queues of the queue.
|
abstract float |
getCurrentCapacity()
Get the current capacity of the queue.
|
abstract String |
getDefaultNodeLabelExpression()
Get the
default node label expression of the queue, this takes
affect only when the ApplicationSubmissionContext and
ResourceRequest don't specify their
NodeLabelExpression . |
abstract Boolean |
getIntraQueuePreemptionDisabled()
Get the intra-queue preemption status of the queue.
|
abstract float |
getMaximumCapacity()
Get the maximum capacity of the queue.
|
abstract int |
getMaxParallelApps()
Get the configured max parallel apps of the queue.
|
abstract long |
getMaxResourceMemory()
Get the maximum resource Memory.
|
abstract int |
getMaxResourceVCore()
Get the maximum resource VCore.
|
abstract int |
getMaxRunningApp()
Get the MaxRunningApp.
|
abstract long |
getMinResourceMemory()
Get the minimum resource Memory.
|
abstract int |
getMinResourceVCore()
Get the minimum resource VCore.
|
abstract Boolean |
getPreemptionDisabled()
Get the preemption status of the queue.
|
abstract Map<String,QueueConfigurations> |
getQueueConfigurations()
Get the per-node-label queue configurations of the queue.
|
abstract String |
getQueueName()
Get the name of the queue.
|
abstract String |
getQueuePath()
Get the path of the queue.
|
abstract QueueState |
getQueueState()
Get the
QueueState of the queue. |
abstract QueueStatistics |
getQueueStatistics()
Get the
queue stats for the queue |
abstract long |
getReservedResourceMemory()
Get the reserved resource Memory.
|
abstract int |
getReservedResourceVCore()
Get the reserved resource VCore.
|
abstract String |
getSchedulerType()
Get Scheduler type.
|
abstract long |
getSteadyFairShareMemory()
Get the SteadyFairShare Memory.
|
abstract int |
getSteadyFairShareVCore()
Get the SteadyFairShare VCore.
|
abstract String |
getSubClusterId()
Get the SubClusterId.
|
abstract float |
getWeight()
Get the configured weight of the queue.
|
static QueueInfo |
newInstance(String queueName,
String queuePath,
float capacity,
float maximumCapacity,
float currentCapacity,
List<QueueInfo> childQueues,
List<ApplicationReport> applications,
QueueState queueState,
Set<String> accessibleNodeLabels,
String defaultNodeLabelExpression,
QueueStatistics queueStatistics,
boolean preemptionDisabled,
float weight,
int maxParallelApps) |
static QueueInfo |
newInstance(String queueName,
String queuePath,
float capacity,
float maximumCapacity,
float currentCapacity,
List<QueueInfo> childQueues,
List<ApplicationReport> applications,
QueueState queueState,
Set<String> accessibleNodeLabels,
String defaultNodeLabelExpression,
QueueStatistics queueStatistics,
boolean preemptionDisabled,
float weight,
int maxParallelApps,
Map<String,QueueConfigurations> queueConfigurations) |
static QueueInfo |
newInstance(String queueName,
String queuePath,
float capacity,
float maximumCapacity,
float currentCapacity,
List<QueueInfo> childQueues,
List<ApplicationReport> applications,
QueueState queueState,
Set<String> accessibleNodeLabels,
String defaultNodeLabelExpression,
QueueStatistics queueStatistics,
boolean preemptionDisabled,
float weight,
int maxParallelApps,
Map<String,QueueConfigurations> queueConfigurations,
boolean intraQueuePreemptionDisabled) |
abstract void |
setAccessibleNodeLabels(Set<String> labels)
Set the
accessible node labels of the queue. |
abstract void |
setApplications(List<ApplicationReport> applications) |
abstract void |
setCapacity(float capacity) |
abstract void |
setChildQueues(List<QueueInfo> childQueues) |
abstract void |
setCurrentCapacity(float currentCapacity) |
abstract void |
setDefaultNodeLabelExpression(String defaultLabelExpression) |
abstract void |
setIntraQueuePreemptionDisabled(boolean intraQueuePreemptionDisabled) |
abstract void |
setMaximumCapacity(float maximumCapacity) |
abstract void |
setMaxParallelApps(int maxParallelApps) |
abstract void |
setMaxResourceMemory(long memory)
Set the maximum resource Memory.
|
abstract void |
setMaxResourceVCore(int vCore)
Set the maximum resource Memory.
|
abstract void |
setMaxRunningApp(int maxRunningApp) |
abstract void |
setMinResourceMemory(long memory)
Set the minimum resource Memory.
|
abstract void |
setMinResourceVCore(int vCore)
Set the minimum resource VCore.
|
abstract void |
setPreemptionDisabled(boolean preemptionDisabled) |
abstract void |
setQueueConfigurations(Map<String,QueueConfigurations> queueConfigurations)
Set the per-node-label queue configurations for the queue.
|
abstract void |
setQueueName(String queueName) |
abstract void |
setQueuePath(String queuePath) |
abstract void |
setQueueState(QueueState queueState) |
abstract void |
setQueueStatistics(QueueStatistics queueStatistics)
Set the queue statistics for the queue
|
abstract void |
setReservedResourceMemory(long memory)
Set the reserved resource Memory.
|
abstract void |
setReservedResourceVCore(int vCore)
Set the reserved resource VCore.
|
abstract void |
setSchedulerType(String schedulerType)
Set Scheduler type.
|
abstract void |
setSteadyFairShareMemory(long memory)
Set the SteadyFairShare Memory.
|
abstract void |
setSteadyFairShareVCore(int vCore)
Set the SteadyFairShare VCore.
|
abstract void |
setSubClusterId(String subClusterId)
Set the SubClusterId.
|
abstract void |
setWeight(float weight) |
@InterfaceAudience.Private @InterfaceStability.Unstable public static QueueInfo newInstance(String queueName, String queuePath, float capacity, float maximumCapacity, float currentCapacity, List<QueueInfo> childQueues, List<ApplicationReport> applications, QueueState queueState, Set<String> accessibleNodeLabels, String defaultNodeLabelExpression, QueueStatistics queueStatistics, boolean preemptionDisabled, float weight, int maxParallelApps)
@InterfaceAudience.Private @InterfaceStability.Unstable public static QueueInfo newInstance(String queueName, String queuePath, float capacity, float maximumCapacity, float currentCapacity, List<QueueInfo> childQueues, List<ApplicationReport> applications, QueueState queueState, Set<String> accessibleNodeLabels, String defaultNodeLabelExpression, QueueStatistics queueStatistics, boolean preemptionDisabled, float weight, int maxParallelApps, Map<String,QueueConfigurations> queueConfigurations)
@InterfaceAudience.Private @InterfaceStability.Unstable public static QueueInfo newInstance(String queueName, String queuePath, float capacity, float maximumCapacity, float currentCapacity, List<QueueInfo> childQueues, List<ApplicationReport> applications, QueueState queueState, Set<String> accessibleNodeLabels, String defaultNodeLabelExpression, QueueStatistics queueStatistics, boolean preemptionDisabled, float weight, int maxParallelApps, Map<String,QueueConfigurations> queueConfigurations, boolean intraQueuePreemptionDisabled)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract String getQueueName()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setQueueName(String queueName)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract String getQueuePath()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setQueuePath(String queuePath)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract float getCapacity()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setCapacity(float capacity)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract float getWeight()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setWeight(float weight)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getMaxParallelApps()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMaxParallelApps(int maxParallelApps)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract float getMaximumCapacity()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMaximumCapacity(float maximumCapacity)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract float getCurrentCapacity()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setCurrentCapacity(float currentCapacity)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract List<QueueInfo> getChildQueues()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setChildQueues(List<QueueInfo> childQueues)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract List<ApplicationReport> getApplications()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setApplications(List<ApplicationReport> applications)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract QueueState getQueueState()
QueueState
of the queue.QueueState
of the queue@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setQueueState(QueueState queueState)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract Set<String> getAccessibleNodeLabels()
accessible node labels
of the queue.accessible node labels
of the queue@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setAccessibleNodeLabels(Set<String> labels)
accessible node labels
of the queue.labels
- node label expression of the queue.@InterfaceAudience.Public @InterfaceStability.Stable public abstract String getDefaultNodeLabelExpression()
default node label expression
of the queue, this takes
affect only when the ApplicationSubmissionContext
and
ResourceRequest
don't specify their
NodeLabelExpression
.default node label expression
of the queue@InterfaceAudience.Public @InterfaceStability.Stable public abstract void setDefaultNodeLabelExpression(String defaultLabelExpression)
@InterfaceAudience.Public @InterfaceStability.Unstable public abstract QueueStatistics getQueueStatistics()
queue stats
for the queuequeue stats
of the queue@InterfaceAudience.Public @InterfaceStability.Unstable public abstract void setQueueStatistics(QueueStatistics queueStatistics)
queueStatistics
- the queue statistics@InterfaceAudience.Public @InterfaceStability.Stable public abstract Boolean getPreemptionDisabled()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setPreemptionDisabled(boolean preemptionDisabled)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract Map<String,QueueConfigurations> getQueueConfigurations()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setQueueConfigurations(Map<String,QueueConfigurations> queueConfigurations)
queueConfigurations
- the queue configurations@InterfaceAudience.Public @InterfaceStability.Stable public abstract Boolean getIntraQueuePreemptionDisabled()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setIntraQueuePreemptionDisabled(boolean intraQueuePreemptionDisabled)
@InterfaceAudience.Public @InterfaceStability.Stable public abstract String getSchedulerType()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setSchedulerType(String schedulerType)
schedulerType
- scheduler Type.@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getMinResourceVCore()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMinResourceVCore(int vCore)
vCore
- minimum resource VCore.@InterfaceAudience.Public @InterfaceStability.Stable public abstract long getMinResourceMemory()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMinResourceMemory(long memory)
memory
- minimum resource Memory.@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getMaxResourceVCore()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMaxResourceVCore(int vCore)
vCore
- maximum resource VCore.@InterfaceAudience.Public @InterfaceStability.Stable public abstract long getMaxResourceMemory()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMaxResourceMemory(long memory)
memory
- maximum resource Memory.@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getReservedResourceVCore()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setReservedResourceVCore(int vCore)
vCore
- reserved resource VCore.@InterfaceAudience.Public @InterfaceStability.Stable public abstract long getReservedResourceMemory()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setReservedResourceMemory(long memory)
memory
- reserved resource Memory.@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getSteadyFairShareVCore()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setSteadyFairShareVCore(int vCore)
vCore
- SteadyFairShare VCore.@InterfaceAudience.Public @InterfaceStability.Stable public abstract long getSteadyFairShareMemory()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setSteadyFairShareMemory(long memory)
memory
- SteadyFairShare Memory.@InterfaceAudience.Public @InterfaceStability.Stable public abstract String getSubClusterId()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setSubClusterId(String subClusterId)
subClusterId
- the SubClusterId.@InterfaceAudience.Public @InterfaceStability.Stable public abstract int getMaxRunningApp()
@InterfaceAudience.Private @InterfaceStability.Unstable public abstract void setMaxRunningApp(int maxRunningApp)
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.