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

ApplicationClientProtocol.cancelDelegationToken介绍

暂无

代码示例

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

@Override
public CancelDelegationTokenResponse cancelDelegationToken(
  CancelDelegationTokenRequest request) throws YarnException, IOException {
 return clientRMProxy.cancelDelegationToken(request);
}

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

@Override
public CancelDelegationTokenResponseProto cancelDelegationToken(
  RpcController controller, CancelDelegationTokenRequestProto proto)
  throws ServiceException {
 CancelDelegationTokenRequestPBImpl request =
   new CancelDelegationTokenRequestPBImpl(proto);
  try {
   CancelDelegationTokenResponse response = real.cancelDelegationToken(request);
   return ((CancelDelegationTokenResponsePBImpl)response).getProto();
  } catch (YarnException e) {
   throw new ServiceException(e);
  } catch (IOException e) {
   throw new ServiceException(e);
  }
}

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

@Override
public CancelDelegationTokenResponseProto cancelDelegationToken(
  RpcController controller, CancelDelegationTokenRequestProto proto)
  throws ServiceException {
 CancelDelegationTokenRequestPBImpl request =
   new CancelDelegationTokenRequestPBImpl(proto);
  try {
   CancelDelegationTokenResponse response = real.cancelDelegationToken(request);
   return ((CancelDelegationTokenResponsePBImpl)response).getProto();
  } catch (YarnException e) {
   throw new ServiceException(e);
  } catch (IOException e) {
   throw new ServiceException(e);
  }
}

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

@Override
public CancelDelegationTokenResponseProto cancelDelegationToken(
  RpcController controller, CancelDelegationTokenRequestProto proto)
  throws ServiceException {
 CancelDelegationTokenRequestPBImpl request =
   new CancelDelegationTokenRequestPBImpl(proto);
  try {
   CancelDelegationTokenResponse response = real.cancelDelegationToken(request);
   return ((CancelDelegationTokenResponsePBImpl)response).getProto();
  } catch (YarnException e) {
   throw new ServiceException(e);
  } catch (IOException e) {
   throw new ServiceException(e);
  }
}

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

@Override
 public Void run() throws YarnException, IOException {
  CancelDelegationTokenRequest request = Records
    .newRecord(CancelDelegationTokenRequest.class);
  request.setDelegationToken(dToken);
  clientRMService.cancelDelegationToken(request);
  return null;
 }
});

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

@Override
 public Void run() throws YarnException, IOException {
  CancelDelegationTokenRequest request = Records
    .newRecord(CancelDelegationTokenRequest.class);
  request.setDelegationToken(dToken);
  clientRMService.cancelDelegationToken(request);
  return null;
 }
});

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

@SuppressWarnings("unchecked")
@Override
public void cancel(Token<?> token, Configuration conf) throws IOException,
  InterruptedException {
 final ApplicationClientProtocol rmClient = getRmClient(token, conf);
 if (rmClient != null) {
  try {
   CancelDelegationTokenRequest request =
     Records.newRecord(CancelDelegationTokenRequest.class);
   request.setDelegationToken(convertToProtoToken(token));
   rmClient.cancelDelegationToken(request);
  } catch (YarnException e) {
   throw new IOException(e);
  } finally {
   RPC.stopProxy(rmClient);
  }
 } else {
  localSecretManager.cancelToken(
    (Token<RMDelegationTokenIdentifier>)token, getRenewer(token));
 }
}

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

@SuppressWarnings("unchecked")
@Override
public void cancel(Token<?> token, Configuration conf) throws IOException,
  InterruptedException {
 final ApplicationClientProtocol rmClient = getRmClient(token, conf);
 if (rmClient != null) {
  try {
   CancelDelegationTokenRequest request =
     Records.newRecord(CancelDelegationTokenRequest.class);
   request.setDelegationToken(convertToProtoToken(token));
   rmClient.cancelDelegationToken(request);
  } catch (YarnException e) {
   throw new IOException(e);
  } finally {
   RPC.stopProxy(rmClient);
  }
 } else {
  localSecretManager.cancelToken(
    (Token<RMDelegationTokenIdentifier>)token, getRenewer(token));
 }
}

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

@SuppressWarnings("unchecked")
@Override
public void cancel(Token<?> token, Configuration conf) throws IOException,
  InterruptedException {
 final ApplicationClientProtocol rmClient = getRmClient(token, conf);
 if (rmClient != null) {
  try {
   CancelDelegationTokenRequest request =
     Records.newRecord(CancelDelegationTokenRequest.class);
   request.setDelegationToken(convertToProtoToken(token));
   rmClient.cancelDelegationToken(request);
  } catch (YarnException e) {
   throw new IOException(e);
  } finally {
   RPC.stopProxy(rmClient);
  }
 } else {
  localSecretManager.cancelToken(
    (Token<RMDelegationTokenIdentifier>)token, getRenewer(token));
 }
}