|
@@ -76,6 +76,7 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
|
private static final Log LOG = LogFactory.getLog(AbstractCSQueue.class);
|
|
|
volatile CSQueue parent;
|
|
|
final String queueName;
|
|
|
+ private final String queuePath;
|
|
|
volatile int numContainers;
|
|
|
|
|
|
final Resource minimumAllocation;
|
|
@@ -119,6 +120,8 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
|
this.labelManager = cs.getRMContext().getNodeLabelManager();
|
|
|
this.parent = parent;
|
|
|
this.queueName = queueName;
|
|
|
+ this.queuePath =
|
|
|
+ ((parent == null) ? "" : (parent.getQueuePath() + ".")) + this.queueName;
|
|
|
this.resourceCalculator = cs.getResourceCalculator();
|
|
|
this.activitiesManager = cs.getActivitiesManager();
|
|
|
|
|
@@ -150,6 +153,11 @@ public abstract class AbstractCSQueue implements CSQueue {
|
|
|
queueCapacities,
|
|
|
parent == null ? null : parent.getQueueCapacities());
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String getQueuePath() {
|
|
|
+ return queuePath;
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
|
public float getCapacity() {
|