微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

org.apache.hadoop.mapreduce.v2.api.protocolrecords.GetDelegationTokenRequest的实例源码

项目:hadoop    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,final MRClientProtocol hsService,final String renewerString)
    throws IOException,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:aliyun-oss-hadoop-fs    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:big-c    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hadoop-2.6.0-cdh5.4.3    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hadoop-plus    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:FlexMap    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hops    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hadoop-TCP    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hardfs    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:hadoop-on-lustre2    文件TestJHSSecurity.java   
private Token getDelegationToken(
    final UserGroupinformation loggedInUser,InterruptedException {
  // Get the delegation token directly as it is a little difficult to setup
  // the kerberos based rpc.
  Token token = loggedInUser
      .doAs(new PrivilegedExceptionAction<Token>() {
        @Override
        public Token run() throws IOException {
          GetDelegationTokenRequest request = Records
              .newRecord(GetDelegationTokenRequest.class);
          request.setRenewer(renewerString);
          return hsService.getDelegationToken(request).getDelegationToken();
        }

      });
  return token;
}
项目:big_data    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy) throws IOException,InterruptedException {
    GetDelegationTokenRequest request = recordFactory.newRecordInstance(GetDelegationTokenRequest.class);
    request.setRenewer(Master.getMasterPrincipal(conf));
    org.apache.hadoop.yarn.api.records.Token mrDelegationToken;
    mrDelegationToken = hsProxy.getDelegationToken(request).getDelegationToken();
    return ConverterUtils.convertFromYarn(mrDelegationToken,hsProxy.getConnectAddress());
}
项目:hadoop    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,InterruptedException {
  GetDelegationTokenRequest request = recordFactory
    .newRecordInstance(GetDelegationTokenRequest.class);
  request.setRenewer(Master.getMasterPrincipal(conf));
  org.apache.hadoop.yarn.api.records.Token mrDelegationToken;
  mrDelegationToken = hsProxy.getDelegationToken(request)
      .getDelegationToken();
  return ConverterUtils.convertFromYarn(mrDelegationToken,hsProxy.getConnectAddress());
}
项目:hadoop    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:hadoop    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:aliyun-oss-hadoop-fs    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:aliyun-oss-hadoop-fs    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:aliyun-oss-hadoop-fs    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:aliyun-oss-hadoop-fs    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,new Text(
        request.getRenewer()),realUser);
  Token<MRDelegationTokenIdentifier> realJHSToken =
      new Token<MRDelegationTokenIdentifier>(tokenIdentifier,jhsDTSecretManager);
  org.apache.hadoop.yarn.api.records.Token mrDToken =
      org.apache.hadoop.yarn.api.records.Token.newInstance(
        realJHSToken.getIdentifier(),realJHSToken.getKind().toString(),realJHSToken.getpassword(),realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:big-c    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:big-c    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:big-c    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:big-c    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:hadoop-2.6.0-cdh5.4.3    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:hadoop-2.6.0-cdh5.4.3    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:hadoop-plus    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:hadoop-plus    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:hadoop-plus    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:hadoop-plus    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:FlexMap    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:FlexMap    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:FlexMap    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:FlexMap    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:hops    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}
项目:hops    文件MRClientProtocolPBServiceImpl.java   
@Override
public GetDelegationTokenResponseProto getDelegationToken(
    RpcController controller,GetDelegationTokenRequestProto proto)
    throws ServiceException {
  GetDelegationTokenRequest request = new GetDelegationTokenRequestPBImpl(proto);
  try {
    GetDelegationTokenResponse response = real.getDelegationToken(request);
    return ((GetDelegationTokenResponsePBImpl)response).getProto();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
项目:hops    文件MRClientProtocolPBClientImpl.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {
  GetDelegationTokenRequestProto requestProto = ((GetDelegationTokenRequestPBImpl)
      request).getProto();
  try {
    return new GetDelegationTokenResponsePBImpl(proxy.getDelegationToken(
        null,requestProto));
  } catch (ServiceException e) {
    throw unwrapAndThrowException(e);
  }
}
项目:hops    文件HistoryClientService.java   
@Override
public GetDelegationTokenResponse getDelegationToken(
    GetDelegationTokenRequest request) throws IOException {

  UserGroupinformation ugi = UserGroupinformation.getCurrentUser();

  // Verify that the connection is kerberos authenticated
    if (!isAllowedDelegationTokenop()) {
      throw new IOException(
          "Delegation Token can be issued only with kerberos authentication");
    }

  GetDelegationTokenResponse response = recordFactory.newRecordInstance(
      GetDelegationTokenResponse.class);

  String user = ugi.getUserName();
  Text owner = new Text(user);
  Text realUser = null;
  if (ugi.getRealUser() != null) {
    realUser = new Text(ugi.getRealUser().getUserName());
  }
  MRDelegationTokenIdentifier tokenIdentifier =
      new MRDelegationTokenIdentifier(owner,realJHSToken.getService().toString());
  response.setDelegationToken(mrDToken);
  return response;
}
项目:incubator-gobblin    文件TokenUtils.java   
private static Token<?> getDelegationTokenFromHS(HSClientProtocol hsProxy,Configuration conf) throws IOException {
  GetDelegationTokenRequest request =
      RecordFactoryProvider.getRecordFactory(null).newRecordInstance(GetDelegationTokenRequest.class);
  request.setRenewer(Master.getMasterPrincipal(conf));
  org.apache.hadoop.yarn.api.records.Token mrDelegationToken;
  mrDelegationToken = hsProxy.getDelegationToken(request).getDelegationToken();
  return ConverterUtils.convertFromYarn(mrDelegationToken,hsProxy.getConnectAddress());
}
项目:hadoop-TCP    文件YARNRunner.java   
@VisibleForTesting
Token<?> getDelegationTokenFromHS(MRClientProtocol hsProxy)
    throws IOException,hsProxy.getConnectAddress());
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。