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

YarnScheduler.getMaximumResourceCapability介绍

[英]Get maximum allocatable Resource at the cluster level.
[中]在群集级别获取最大可分配资源。

代码示例

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

@Override
public GetNewApplicationResponse getNewApplication(
  GetNewApplicationRequest request) throws YarnException {
 GetNewApplicationResponse response = recordFactory
   .newRecordInstance(GetNewApplicationResponse.class);
 response.setApplicationId(getNewApplicationId());
 // Pick up min/max resource from scheduler...
 response.setMaximumResourceCapability(scheduler
   .getMaximumResourceCapability());       
 
 return response;
}

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

@Override
public GetNewApplicationResponse getNewApplication(
  GetNewApplicationRequest request) throws YarnException {
 GetNewApplicationResponse response = recordFactory
   .newRecordInstance(GetNewApplicationResponse.class);
 response.setApplicationId(getNewApplicationId());
 // Pick up min/max resource from scheduler...
 response.setMaximumResourceCapability(scheduler
   .getMaximumResourceCapability());       
 
 return response;
}

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

@Override
public GetNewApplicationResponse getNewApplication(
  GetNewApplicationRequest request) throws YarnException {
 GetNewApplicationResponse response = recordFactory
   .newRecordInstance(GetNewApplicationResponse.class);
 response.setApplicationId(getNewApplicationId());
 // Pick up min/max resource from scheduler...
 response.setMaximumResourceCapability(scheduler
   .getMaximumResourceCapability());       
 
 return response;
}

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

private static YarnScheduler mockYarnScheduler() {
 YarnScheduler yarnScheduler = mock(YarnScheduler.class);
 when(yarnScheduler.getMinimumResourceCapability()).thenReturn(
   Resources.createResource(
     YarnConfiguration.DEFAULT_RM_SCHEDULER_MINIMUM_ALLOCATION_MB));
 when(yarnScheduler.getMaximumResourceCapability()).thenReturn(
   Resources.createResource(
     YarnConfiguration.DEFAULT_RM_SCHEDULER_MAXIMUM_ALLOCATION_MB));
 when(yarnScheduler.getAppsInQueue(QUEUE_1)).thenReturn(
   Arrays.asList(getApplicationAttemptId(101), getApplicationAttemptId(102)));
 when(yarnScheduler.getAppsInQueue(QUEUE_2)).thenReturn(
   Arrays.asList(getApplicationAttemptId(103)));
 ApplicationAttemptId attemptId = getApplicationAttemptId(1);
 when(yarnScheduler.getAppResourceUsageReport(attemptId)).thenReturn(null);
 ResourceCalculator rc = new DefaultResourceCalculator();
 when(yarnScheduler.getResourceCalculator()).thenReturn(rc);
 return yarnScheduler;
}

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

scheduler.getMaximumResourceCapability(),
   submissionContext.getQueue(), scheduler, isRecovery, rmContext);
} catch (InvalidResourceRequestException e) {
  scheduler.getClusterResource(),
  scheduler.getMinimumResourceCapability(),
  scheduler.getMaximumResourceCapability(),
  scheduler.getMinimumResourceCapability());
return amReq;

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

scheduler.getMaximumResourceCapability(),
   submissionContext.getQueue(), scheduler, isRecovery, rmContext);
} catch (InvalidResourceRequestException e) {
  scheduler.getClusterResource(),
  scheduler.getMinimumResourceCapability(),
  scheduler.getMaximumResourceCapability(),
  scheduler.getMinimumResourceCapability());
return amReq;

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

private void verifyMaximumResourceCapability(
  Resource expectedMaximumResource, YarnScheduler scheduler) {
 final Resource schedulerMaximumResourceCapability = scheduler
   .getMaximumResourceCapability();
 Assert.assertEquals(expectedMaximumResource.getMemorySize(),
   schedulerMaximumResourceCapability.getMemorySize());
 Assert.assertEquals(expectedMaximumResource.getVirtualCores(),
   schedulerMaximumResourceCapability.getVirtualCores());
}

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

Resource maxAllocation = scheduler.getMaximumResourceCapability(queue);
for (ResourceRequest amReq : amReqs) {
 SchedulerUtils.normalizeAndValidateRequest(amReq, maxAllocation,

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

.newRecordInstance(RegisterApplicationMasterResponse.class);
response.setMaximumResourceCapability(rScheduler
  .getMaximumResourceCapability(app.getQueue()));
response.setApplicationACLs(app.getRMAppAttempt(applicationAttemptId)
  .getSubmissionContext().getAMContainerSpec().getApplicationACLs());

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

opCtx.updateAllocationParams(
  getScheduler().getMinimumResourceCapability(),
  getScheduler().getMaximumResourceCapability(),
  getScheduler().getMinimumResourceCapability(),
  tokenExpiryInterval);

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

.newRecordInstance(RegisterApplicationMasterResponse.class);
response.setMaximumResourceCapability(rScheduler
  .getMaximumResourceCapability(app.getQueue()));
response.setApplicationACLs(app.getRMAppAttempt(applicationAttemptId)
  .getSubmissionContext().getAMContainerSpec().getApplicationACLs());

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

applicationAttemptId);
response.setMaximumResourceCapability(getScheduler()
  .getMaximumResourceCapability(app.getQueue()));
response.setApplicationACLs(app.getRMAppAttempt(applicationAttemptId)
  .getSubmissionContext().getAMContainerSpec().getApplicationACLs());

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

getScheduler().getMaximumResourceCapability(app.getQueue());

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

rScheduler.getMaximumResourceCapability(), app.getQueue(),
   rScheduler, rmContext);
} catch (InvalidResourceRequestException e) {

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

rScheduler.getMaximumResourceCapability(), app.getQueue(),
   rScheduler, rmContext);
} catch (InvalidResourceRequestException e) {

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

int maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[0], maxVCores);
scheduler.handle(new NodeAddedSchedulerEvent(node1));
Assert.assertEquals(1, scheduler.getNumClusterNodes());
maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[1], maxVCores);
maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[2], maxVCores);
scheduler.handle(new NodeAddedSchedulerEvent(node2));
Assert.assertEquals(1, scheduler.getNumClusterNodes());
maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[3], maxVCores);
scheduler.handle(new NodeAddedSchedulerEvent(node3));
Assert.assertEquals(2, scheduler.getNumClusterNodes());
maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[4], maxVCores);
maxVCores = scheduler.getMaximumResourceCapability().getVirtualCores();
Assert.assertEquals(expectedMaxVCores[5], maxVCores);

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

long maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[0], maxMemory);
scheduler.handle(new NodeAddedSchedulerEvent(node1));
Assert.assertEquals(1, scheduler.getNumClusterNodes());
maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[1], maxMemory);
maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[2], maxMemory);
scheduler.handle(new NodeAddedSchedulerEvent(node2));
Assert.assertEquals(1, scheduler.getNumClusterNodes());
maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[3], maxMemory);
scheduler.handle(new NodeAddedSchedulerEvent(node3));
Assert.assertEquals(2, scheduler.getNumClusterNodes());
maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[4], maxMemory);
maxMemory = scheduler.getMaximumResourceCapability().getMemorySize();
Assert.assertEquals(expectedMaxMemory[5], maxMemory);