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

YarnAuthorizationProvider.setAdmins介绍

[英]Set a list of users/groups who have admin access
[中]设置具有管理员权限的用户/组列表

代码示例

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

private RefreshAdminAclsResponse refreshAdminAcls(boolean checkRMHAState)
  throws YarnException, IOException {
 String argName = "refreshAdminAcls";
 UserGroupInformation user = checkAcls(argName);
 if (checkRMHAState) {
  checkRMStatus(user.getShortUserName(), argName, "refresh Admin ACLs.");
 }
 Configuration conf =
   getConfiguration(new Configuration(false),
     YarnConfiguration.YARN_SITE_CONFIGURATION_FILE);
 authorizer.setAdmins(getAdminAclList(conf), UserGroupInformation
   .getCurrentUser());
 RMAuditLogger.logSuccess(user.getShortUserName(), argName,
   "AdminService");
 return recordFactory.newRecordInstance(RefreshAdminAclsResponse.class);
}

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

private RefreshAdminAclsResponse refreshAdminAcls(boolean checkRMHAState)
  throws YarnException, IOException {
 String argName = "refreshAdminAcls";
 UserGroupInformation user = checkAcls(argName);
 if (checkRMHAState) {
  checkRMStatus(user.getShortUserName(), argName, "refresh Admin ACLs.");
 }
 Configuration conf =
   getConfiguration(new Configuration(false),
     YarnConfiguration.YARN_SITE_CONFIGURATION_FILE);
 authorizer.setAdmins(getAdminAclList(conf), UserGroupInformation
   .getCurrentUser());
 RMAuditLogger.logSuccess(user.getShortUserName(), argName,
   "AdminService");
 return recordFactory.newRecordInstance(RefreshAdminAclsResponse.class);
}

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

private RefreshAdminAclsResponse refreshAdminAcls(boolean checkRMHAState)
  throws YarnException, IOException {
 final String operation = "refreshAdminAcls";
 UserGroupInformation user = checkAcls(operation);
 if (checkRMHAState) {
  checkRMStatus(user.getShortUserName(), operation, "refresh Admin ACLs.");
 }
 Configuration conf =
   getConfiguration(new Configuration(false),
     YarnConfiguration.YARN_SITE_CONFIGURATION_FILE);
 authorizer.setAdmins(getAdminAclList(conf), daemonUser);
 RMAuditLogger.logSuccess(user.getShortUserName(), operation,
   "AdminService");
 return recordFactory.newRecordInstance(RefreshAdminAclsResponse.class);
}

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

@Override
public void serviceInit(Configuration conf) throws Exception {
 autoFailoverEnabled =
   rm.getRMContext().isHAEnabled()
     && HAUtil.isAutomaticFailoverEnabled(conf);
 masterServiceBindAddress = conf.getSocketAddr(
   YarnConfiguration.RM_BIND_HOST,
   YarnConfiguration.RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_PORT);
 daemonUser = UserGroupInformation.getCurrentUser();
 authorizer = YarnAuthorizationProvider.getInstance(conf);
 authorizer.setAdmins(getAdminAclList(conf), daemonUser);
 rmId = conf.get(YarnConfiguration.RM_HA_ID);
 isCentralizedNodeLabelConfiguration =
   YarnConfiguration.isCentralizedNodeLabelConfiguration(conf);
 super.serviceInit(conf);
}

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

@Override
public void serviceInit(Configuration conf) throws Exception {
 if (rmContext.isHAEnabled()) {
  autoFailoverEnabled = HAUtil.isAutomaticFailoverEnabled(conf);
  if (autoFailoverEnabled) {
   if (HAUtil.isAutomaticFailoverEmbedded(conf)) {
    embeddedElector = createEmbeddedElectorService();
    addIfService(embeddedElector);
   }
  }
 }
 masterServiceBindAddress = conf.getSocketAddr(
   YarnConfiguration.RM_BIND_HOST,
   YarnConfiguration.RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_PORT);
 daemonUser = UserGroupInformation.getCurrentUser();
 authorizer = YarnAuthorizationProvider.getInstance(conf);
 authorizer.setAdmins(getAdminAclList(conf), UserGroupInformation
   .getCurrentUser());
 rmId = conf.get(YarnConfiguration.RM_HA_ID);
 super.serviceInit(conf);
}

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

@Override
public void serviceInit(Configuration conf) throws Exception {
 if (rmContext.isHAEnabled()) {
  autoFailoverEnabled = HAUtil.isAutomaticFailoverEnabled(conf);
  if (autoFailoverEnabled) {
   if (HAUtil.isAutomaticFailoverEmbedded(conf)) {
    embeddedElector = createEmbeddedElectorService();
    addIfService(embeddedElector);
   }
  }
 }
 masterServiceBindAddress = conf.getSocketAddr(
   YarnConfiguration.RM_BIND_HOST,
   YarnConfiguration.RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_ADDRESS,
   YarnConfiguration.DEFAULT_RM_ADMIN_PORT);
 daemonUser = UserGroupInformation.getCurrentUser();
 authorizer = YarnAuthorizationProvider.getInstance(conf);
 authorizer.setAdmins(getAdminAclList(conf), UserGroupInformation
   .getCurrentUser());
 rmId = conf.get(YarnConfiguration.RM_HA_ID);
 super.serviceInit(conf);
}