org.apache.hadoop.yarn.security.YarnAuthorizationProvider.getInstance()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(82)

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

YarnAuthorizationProvider.getInstance介绍

暂无

代码示例

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

@Override
public void init(Configuration config, RMContext context) {
 this.conf = config;
 this.rmContext = context;
 this.authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

@Override
public void init(Configuration conf, RMContext rmContext) {
 authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

public QueueACLsManager(ResourceScheduler scheduler, Configuration conf) {
 this.scheduler = scheduler;
 this.isACLsEnable = conf.getBoolean(YarnConfiguration.YARN_ACL_ENABLE,
   YarnConfiguration.DEFAULT_YARN_ACL_ENABLE);
 this.authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

public RMAppManager(RMContext context,
  YarnScheduler scheduler, ApplicationMasterService masterService,
  ApplicationACLsManager applicationACLsManager, Configuration conf) {
 this.rmContext = context;
 this.scheduler = scheduler;
 this.masterService = masterService;
 this.applicationACLsManager = applicationACLsManager;
 this.conf = conf;
 this.maxCompletedAppsInMemory = conf.getInt(
   YarnConfiguration.RM_MAX_COMPLETED_APPLICATIONS,
   YarnConfiguration.DEFAULT_RM_MAX_COMPLETED_APPLICATIONS);
 this.maxCompletedAppsInStateStore =
   conf.getInt(
    YarnConfiguration.RM_STATE_STORE_MAX_COMPLETED_APPLICATIONS,
    this.maxCompletedAppsInMemory);
 if (this.maxCompletedAppsInStateStore > this.maxCompletedAppsInMemory) {
  this.maxCompletedAppsInStateStore = this.maxCompletedAppsInMemory;
 }
 this.authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

@Override
protected void serviceInit(Configuration conf) throws Exception {
 super.serviceInit(conf);
 authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

@Override
protected void serviceInit(Configuration conf) throws Exception {
 super.serviceInit(conf);
 authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

@Override
protected void serviceInit(Configuration conf) throws Exception {
 super.serviceInit(conf);
 authorizer = YarnAuthorizationProvider.getInstance(conf);
}

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

/**
 * Construct the service.
 * @param conf the configuration
 * @param labelManager the labelManager
 * @param appPriorityACLManager App priority ACL manager
 */
public CapacitySchedulerQueueManager(Configuration conf,
  RMNodeLabelsManager labelManager,
  AppPriorityACLsManager appPriorityACLManager) {
 this.authorizer = YarnAuthorizationProvider.getInstance(conf);
 this.labelManager = labelManager;
 this.queueStateManager = new QueueStateManager<>();
 this.appPriorityACLManager = appPriorityACLManager;
}

代码示例来源：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: 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);
}

代码示例来源：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: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public FSQueue(String name, FairScheduler scheduler, FSParentQueue parent) {
 this.name = name;
 this.scheduler = scheduler;
 this.authorizer =
   YarnAuthorizationProvider.getInstance(scheduler.getConf());
 this.queueEntity = new PrivilegedEntity(EntityType.QUEUE, name);
 this.metrics = FSQueueMetrics.forQueue(getName(), parent, true, scheduler.getConf());
 this.parent = parent;
 setPolicy(scheduler.getAllocationConfiguration().getSchedulingPolicy(name));
 reinit(false);
}

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

private synchronized void initScheduler(Configuration configuration) throws
  IOException {
 this.conf = loadCapacitySchedulerConfiguration(configuration);
 validateConf(this.conf);
 this.minimumAllocation = this.conf.getMinimumAllocation();
 initMaximumResourceCapability(this.conf.getMaximumAllocation());
 this.calculator = this.conf.getResourceCalculator();
 this.usePortForNodeName = this.conf.getUsePortForNodeName();
 this.applications =
   new ConcurrentHashMap<ApplicationId,
     SchedulerApplication<FiCaSchedulerApp>>();
 this.labelManager = rmContext.getNodeLabelManager();
 authorizer = YarnAuthorizationProvider.getInstance(yarnConf);
 initializeQueues(this.conf);
 scheduleAsynchronously = this.conf.getScheduleAynschronously();
 asyncScheduleInterval =
   this.conf.getLong(ASYNC_SCHEDULER_INTERVAL,
     DEFAULT_ASYNC_SCHEDULER_INTERVAL);
 if (scheduleAsynchronously) {
  asyncSchedulerThread = new AsyncScheduleThread(this);
 }
 LOG.info("Initialized CapacityScheduler with " +
   "calculator=" + getResourceCalculator().getClass() + ", " +
   "minimumAllocation=<" + getMinimumResourceCapability() + ">, " +
   "maximumAllocation=<" + getMaximumResourceCapability() + ">, " +
   "asynchronousScheduling=" + scheduleAsynchronously + ", " +
   "asyncScheduleInterval=" + asyncScheduleInterval + "ms");
}

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

private synchronized void initScheduler(Configuration configuration) throws
  IOException {
 this.conf = loadCapacitySchedulerConfiguration(configuration);
 validateConf(this.conf);
 this.minimumAllocation = this.conf.getMinimumAllocation();
 initMaximumResourceCapability(this.conf.getMaximumAllocation());
 this.calculator = this.conf.getResourceCalculator();
 this.usePortForNodeName = this.conf.getUsePortForNodeName();
 this.applications =
   new ConcurrentHashMap<ApplicationId,
     SchedulerApplication<FiCaSchedulerApp>>();
 this.labelManager = rmContext.getNodeLabelManager();
 authorizer = YarnAuthorizationProvider.getInstance(yarnConf);
 initializeQueues(this.conf);
 scheduleAsynchronously = this.conf.getScheduleAynschronously();
 asyncScheduleInterval =
   this.conf.getLong(ASYNC_SCHEDULER_INTERVAL,
     DEFAULT_ASYNC_SCHEDULER_INTERVAL);
 if (scheduleAsynchronously) {
  asyncSchedulerThread = new AsyncScheduleThread(this);
 }
 LOG.info("Initialized CapacityScheduler with " +
   "calculator=" + getResourceCalculator().getClass() + ", " +
   "minimumAllocation=<" + getMinimumResourceCapability() + ">, " +
   "maximumAllocation=<" + getMaximumResourceCapability() + ">, " +
   "asynchronousScheduling=" + scheduleAsynchronously + ", " +
   "asyncScheduleInterval=" + asyncScheduleInterval + "ms");
}

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

getQueuePath());
authorizer = YarnAuthorizationProvider.getInstance(csContext.getConf());

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

getQueuePath());
authorizer = YarnAuthorizationProvider.getInstance(csContext.getConf());

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

this.conf = new FairSchedulerConfiguration(conf);
validateConf(this.conf);
authorizer = YarnAuthorizationProvider.getInstance(conf);
minimumAllocation = super.getMinimumAllocation();
initMaximumResourceCapability(super.getMaximumAllocation());

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

initializeQueueState(previous, configuredState, parentState);
authorizer = YarnAuthorizationProvider.getInstance(csContext.getConf());

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

TestUtils.spyHook);
YarnAuthorizationProvider authorizer =
  YarnAuthorizationProvider.getInstance(conf);
CapacityScheduler.setQueueAcls(authorizer, queues);

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

TestUtils.spyHook);
YarnAuthorizationProvider authorizer =
  YarnAuthorizationProvider.getInstance(conf);
AppPriorityACLsManager appPriorityACLManager = new AppPriorityACLsManager(
  conf);

内容来源于网络，如有侵权，请联系作者删除！

YarnAuthorizationProvider

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com