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

YarnQueueAclsVerifier.verify介绍

暂无

代码示例

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