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

ApplicationClientProtocol.getDelegationToken介绍

暂无

代码示例

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

@Override
public GetDelegationTokenResponse getDelegationToken(
  GetDelegationTokenRequest request) throws YarnException, IOException {
 return clientRMProxy.getDelegationToken(request);
}

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

@Override
public Token getRMDelegationToken(Text renewer)
  throws YarnException, IOException {
 /* get the token from RM */
 GetDelegationTokenRequest rmDTRequest =
   Records.newRecord(GetDelegationTokenRequest.class);
 rmDTRequest.setRenewer(renewer.toString());
 GetDelegationTokenResponse response =
   rmClient.getDelegationToken(rmDTRequest);
 return response.getRMDelegationToken();
}

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

@Override
public Token getRMDelegationToken(Text renewer)
  throws YarnException, IOException {
 /* get the token from RM */
 GetDelegationTokenRequest rmDTRequest =
   Records.newRecord(GetDelegationTokenRequest.class);
 rmDTRequest.setRenewer(renewer.toString());
 GetDelegationTokenResponse response =
   rmClient.getDelegationToken(rmDTRequest);
 return response.getRMDelegationToken();
}

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

@Override
public Token getRMDelegationToken(Text renewer)
  throws YarnException, IOException {
 /* get the token from RM */
 GetDelegationTokenRequest rmDTRequest =
   Records.newRecord(GetDelegationTokenRequest.class);
 rmDTRequest.setRenewer(renewer.toString());
 GetDelegationTokenResponse response =
   rmClient.getDelegationToken(rmDTRequest);
 return response.getRMDelegationToken();
}

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

@Override
public Token getRMDelegationToken(Text renewer)
  throws YarnException, IOException {
 /* get the token from RM */
 GetDelegationTokenRequest rmDTRequest =
   Records.newRecord(GetDelegationTokenRequest.class);
 rmDTRequest.setRenewer(renewer.toString());
 GetDelegationTokenResponse response =
   rmClient.getDelegationToken(rmDTRequest);
 return response.getRMDelegationToken();
}

代码示例来源：origin: org.springframework.data/spring-yarn-core

@Override
  public Token doInYarn(ApplicationClientProtocol proxy) throws YarnException, IOException {
    GetDelegationTokenRequest request = Records.newRecord(GetDelegationTokenRequest.class);
    request.setRenewer(renewer);
    return proxy.getDelegationToken(request).getRMDelegationToken();
  }
});

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

@Override
public GetDelegationTokenResponseProto getDelegationToken(
  RpcController controller, GetDelegationTokenRequestProto proto)
  throws ServiceException {
 GetDelegationTokenRequestPBImpl request =
   new GetDelegationTokenRequestPBImpl(proto);
  try {
   GetDelegationTokenResponse response = real.getDelegationToken(request);
   return ((GetDelegationTokenResponsePBImpl)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 GetDelegationTokenResponseProto getDelegationToken(
  RpcController controller, GetDelegationTokenRequestProto proto)
  throws ServiceException {
 GetDelegationTokenRequestPBImpl request =
   new GetDelegationTokenRequestPBImpl(proto);
  try {
   GetDelegationTokenResponse response = real.getDelegationToken(request);
   return ((GetDelegationTokenResponsePBImpl)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 GetDelegationTokenResponseProto getDelegationToken(
  RpcController controller, GetDelegationTokenRequestProto proto)
  throws ServiceException {
 GetDelegationTokenRequestPBImpl request =
   new GetDelegationTokenRequestPBImpl(proto);
  try {
   GetDelegationTokenResponse response = real.getDelegationToken(request);
   return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (YarnException e) {
   throw new ServiceException(e);
  } catch (IOException e) {
   throw new ServiceException(e);
  }
}

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

@Override
  public org.apache.hadoop.yarn.api.records.Token run()
    throws YarnException, IOException {
  GetDelegationTokenRequest request = Records
    .newRecord(GetDelegationTokenRequest.class);
  request.setRenewer(renewerString);
  return clientRMService.getDelegationToken(request)
    .getRMDelegationToken();
 }
});

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

@Override
  public org.apache.hadoop.yarn.api.records.Token run()
    throws YarnException, IOException {
  GetDelegationTokenRequest request = Records
    .newRecord(GetDelegationTokenRequest.class);
  request.setRenewer(renewerString);
  return clientRMService.getDelegationToken(request)
    .getRMDelegationToken();
 }
});

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-jobclient

getDTResponse.setRMDelegationToken(rmDTToken);
final ApplicationClientProtocol cRMProtocol = mock(ApplicationClientProtocol.class);
when(cRMProtocol.getDelegationToken(any(
  GetDelegationTokenRequest.class))).thenReturn(getDTResponse);
ResourceMgrDelegate rmgrDelegate = new ResourceMgrDelegate(