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

KMSClientProvider.getActualUgi介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public Void cancelDelegationToken(final Token<?> dToken) throws IOException {
 try {
  final String doAsUser = getDoAsUser();
  final DelegationTokenAuthenticatedURL.Token token =
    generateDelegationToken(dToken);
  return getActualUgi().doAs(
    new PrivilegedExceptionAction<Void>() {
     @Override
     public Void run() throws Exception {
      final URL url = createURL(null, null, null, null);
      LOG.debug("Cancelling delegation token {} with url:{}, as:{}",
        dToken, url, doAsUser);
      final DelegationTokenAuthenticatedURL authUrl =
        createAuthenticatedURL();
      authUrl.cancelDelegationToken(url, token, doAsUser);
      return null;
     }
    }
  );
 } catch (Exception ex) {
  if (ex instanceof IOException) {
   throw (IOException) ex;
  } else {
   throw new IOException(ex);
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

try {
 final String doAsUser = getDoAsUser();
 conn = getActualUgi().doAs(new PrivilegedExceptionAction
   <HttpURLConnection>() {
  @Override

代码示例来源：origin: org.apache.hadoop/hadoop-common

try {
 final String doAsUser = getDoAsUser();
 token = getActualUgi().doAs(new PrivilegedExceptionAction<Token<?>>() {
  @Override
  public Token<?> run() throws Exception {

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public long renewDelegationToken(final Token<?> dToken) throws IOException {
 try {
  final String doAsUser = getDoAsUser();
  final DelegationTokenAuthenticatedURL.Token token =
    generateDelegationToken(dToken);
  final URL url = createURL(null, null, null, null);
  LOG.debug("Renewing delegation token {} with url:{}, as:{}",
    token, url, doAsUser);
  final DelegationTokenAuthenticatedURL authUrl =
    createAuthenticatedURL();
  return getActualUgi().doAs(
    new PrivilegedExceptionAction<Long>() {
     @Override
     public Long run() throws Exception {
      return authUrl.renewDelegationToken(url, token, doAsUser);
     }
    }
  );
 } catch (Exception ex) {
  if (ex instanceof IOException) {
   throw (IOException) ex;
  } else {
   throw new IOException(ex);
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

@Override
public Void cancelDelegationToken(final Token<?> dToken) throws IOException {
 try {
  final String doAsUser = getDoAsUser();
  final DelegationTokenAuthenticatedURL.Token token =
    generateDelegationToken(dToken);
  return getActualUgi().doAs(
    new PrivilegedExceptionAction<Void>() {
     @Override
     public Void run() throws Exception {
      final URL url = createURL(null, null, null, null);
      LOG.debug("Cancelling delegation token {} with url:{}, as:{}",
        dToken, url, doAsUser);
      final DelegationTokenAuthenticatedURL authUrl =
        new DelegationTokenAuthenticatedURL(configurator);
      authUrl.cancelDelegationToken(url, token, doAsUser);
      return null;
     }
    }
  );
 } catch (Exception ex) {
  if (ex instanceof IOException) {
   throw (IOException) ex;
  } else {
   throw new IOException(ex);
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

try {
 final String doAsUser = getDoAsUser();
 conn = getActualUgi().doAs(new PrivilegedExceptionAction
   <HttpURLConnection>() {
  @Override

代码示例来源：origin: io.hops/hadoop-common

@Override
public long renewDelegationToken(final Token<?> dToken) throws IOException {
 try {
  final String doAsUser = getDoAsUser();
  final DelegationTokenAuthenticatedURL.Token token =
    generateDelegationToken(dToken);
  final URL url = createURL(null, null, null, null);
  LOG.debug("Renewing delegation token {} with url:{}, as:{}",
    token, url, doAsUser);
  final DelegationTokenAuthenticatedURL authUrl =
    new DelegationTokenAuthenticatedURL(configurator);
  return getActualUgi().doAs(
    new PrivilegedExceptionAction<Long>() {
     @Override
     public Long run() throws Exception {
      return authUrl.renewDelegationToken(url, token, doAsUser);
     }
    }
  );
 } catch (Exception ex) {
  if (ex instanceof IOException) {
   throw (IOException) ex;
  } else {
   throw new IOException(ex);
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

try {
 final String doAsUser = getDoAsUser();
 token = getActualUgi().doAs(new PrivilegedExceptionAction<Token<?>>() {
  @Override
  public Token<?> run() throws Exception {