gpt4 book ai didi

org.pentaho.hadoop.mapreduce.YarnQueueAclsVerifier类的使用及代码示例

转载 作者:知者 更新时间:2024-03-19 20:23:31 25 4
gpt4 key购买 nike

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

YarnQueueAclsVerifier介绍

暂无

代码示例

代码示例来源:origin: pentaho/pentaho-hadoop-shims

/**
 * Submit job for the current configuration provided by this implementation.
 *
 * @return RunningJob implementation
 */
@Override public RunningJob submit() throws IOException, ClassNotFoundException, InterruptedException {
 JobClient jobClient = createJobClient();
 if ( YarnQueueAclsVerifier.verify( jobClient.getQueueAclsForCurrentUser() ) ) {
  return new RunningJobProxy( jobClient.submitJob( this ) );
 } else {
  throw new YarnQueueAclsException( BaseMessages.getString( ConfigurationProxy.class,
   "ConfigurationProxy.UserHasNoPermissions", UserGroupInformation.getCurrentUser().getUserName() ) );
 }
}

代码示例来源:origin: pentaho/pentaho-hadoop-shims

/**
 * Submit job for the current configuration provided by this implementation.
 *
 * @return RunningJob implementation
 */
@Override public RunningJob submit() throws IOException, ClassNotFoundException, InterruptedException {
 if ( YarnQueueAclsVerifier
  .verify( ( createClusterDescription( getJob().getConfiguration() ) ).getQueueAclsForCurrentUser() ) ) {
  getJob().submit();
  return new RunningJobProxyV2( getJob() );
 } else {
  throw new YarnQueueAclsException( BaseMessages.getString( ConfigurationProxy.class,
   "ConfigurationProxy.UserHasNoPermissions", UserGroupInformation.getCurrentUser().getUserName() ) );
 }
}

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com