本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AllocationConfiguration.getFairSharePreemptionThreshold()方法的一些代码示例，展示了AllocationConfiguration.getFairSharePreemptionThreshold()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AllocationConfiguration.getFairSharePreemptionThreshold()方法的具体详情如下：
包路径：org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AllocationConfiguration
类名称：AllocationConfiguration
方法名：getFairSharePreemptionThreshold

AllocationConfiguration.getFairSharePreemptionThreshold介绍

[英]Get a queue's fair share preemption threshold in the allocation file. Return -1f if not set.
[中]在分配文件中获取队列的公平共享抢占阈值。如果未设置，则返回-1f。

代码示例

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

/**
 * Update the min/fair share preemption timeouts and threshold for this queue.
 */
public void updatePreemptionVariables() {
 // For min share timeout
 minSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getMinSharePreemptionTimeout(getName());
 if (minSharePreemptionTimeout == -1 && parent != null) {
  minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout();
 }
 // For fair share timeout
 fairSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionTimeout(getName());
 if (fairSharePreemptionTimeout == -1 && parent != null) {
  fairSharePreemptionTimeout = parent.getFairSharePreemptionTimeout();
 }
 // For fair share preemption threshold
 fairSharePreemptionThreshold = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionThreshold(getName());
 if (fairSharePreemptionThreshold < 0 && parent != null) {
  fairSharePreemptionThreshold = parent.getFairSharePreemptionThreshold();
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

/**
 * Update the min/fair share preemption timeouts and threshold for this queue.
 */
public void updatePreemptionVariables() {
 // For min share timeout
 minSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getMinSharePreemptionTimeout(getName());
 if (minSharePreemptionTimeout == -1 && parent != null) {
  minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout();
 }
 // For fair share timeout
 fairSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionTimeout(getName());
 if (fairSharePreemptionTimeout == -1 && parent != null) {
  fairSharePreemptionTimeout = parent.getFairSharePreemptionTimeout();
 }
 // For fair share preemption threshold
 fairSharePreemptionThreshold = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionThreshold(getName());
 if (fairSharePreemptionThreshold < 0 && parent != null) {
  fairSharePreemptionThreshold = parent.getFairSharePreemptionThreshold();
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

assertEquals(-1, queueConf.getFairSharePreemptionTimeout("root.queueE"));
assertEquals(.6f, queueConf.getFairSharePreemptionThreshold("root"), 0.01);
assertEquals(-1, queueConf.getFairSharePreemptionThreshold("root."
  + YarnConfiguration.DEFAULT_QUEUE_NAME), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueA"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueB"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueC"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueD"), 0.01);
assertEquals(.3f,
  queueConf.getFairSharePreemptionThreshold("root.queueE"), 0.01);

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

assertEquals(-1, queueConf.getFairSharePreemptionTimeout("root.queueE"));
assertEquals(.6f, queueConf.getFairSharePreemptionThreshold("root"), 0.01);
assertEquals(-1, queueConf.getFairSharePreemptionThreshold("root."
  + YarnConfiguration.DEFAULT_QUEUE_NAME), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueA"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueB"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueC"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueD"), 0.01);
assertEquals(.3f,
  queueConf.getFairSharePreemptionThreshold("root.queueE"), 0.01);

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

.getFairSharePreemptionThreshold(getName());
if (fairSharePreemptionThreshold < 0 && parent != null) {
 fairSharePreemptionThreshold = parent.getFairSharePreemptionThreshold();

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

assertEquals(180000, queueConf.getFairSharePreemptionTimeout("root.queueG.queueH"));
assertEquals(.4f, queueConf.getFairSharePreemptionThreshold("root"), 0.01);
assertEquals(-1, queueConf.getFairSharePreemptionThreshold("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueA"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueB"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueC"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueD"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueE"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueF"), 0.01);
assertEquals(.6f,
  queueConf.getFairSharePreemptionThreshold("root.queueG"), 0.01);
assertEquals(.7f,
  queueConf.getFairSharePreemptionThreshold("root.queueG.queueH"), 0.01);

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

assertEquals(180000, queueConf.getFairSharePreemptionTimeout("root.queueG.queueH"));
assertEquals(.4f, queueConf.getFairSharePreemptionThreshold("root"), 0.01);
assertEquals(-1, queueConf.getFairSharePreemptionThreshold("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueA"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueB"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueC"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueD"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueE"), 0.01);
assertEquals(-1,
  queueConf.getFairSharePreemptionThreshold("root.queueF"), 0.01);
assertEquals(.6f,
  queueConf.getFairSharePreemptionThreshold("root.queueG"), 0.01);
assertEquals(.7f,
  queueConf.getFairSharePreemptionThreshold("root.queueG.queueH"), 0.01);