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

本文整理了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() ) );
}
}