List of renewDelegationToken() Examples

Examples of renewDelegationToken()

org.apache.hadoop.hdfs.DistributedFileSystem.renewDelegationToken()
Renew an existing delegation token. @param token delegation token obtained earlier @return the new expiration time @throws IOException
org.apache.hadoop.hdfs.protocol.ClientProtocol.renewDelegationToken()
Renew an existing delegation token. @param token delegation token obtained earlier @return the new expiration time @throws IOException
org.apache.hadoop.hdfs.server.namenode.FSNamesystem.renewDelegationToken()
@param token @return New expiryTime of the token @throws InvalidToken @throws IOException
org.apache.hadoop.hdfs.server.namenode.NameNode.renewDelegationToken()
org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()
org.apache.hadoop.mapred.JobClient.renewDelegationToken()
Renew a delegation token @param token the token to renew @return the new expiration time @throws InvalidToken @throws IOException
org.apache.hadoop.mapred.JobTracker.renewDelegationToken()
Renew a delegation token to extend its lifetime.
org.apache.hadoop.mapreduce.v2.api.MRClientProtocol.renewDelegationToken()
Renew an existing delegation token. @param request the delegation token to be renewed. @return the new expiry time for the delegation token. @throws YarnRemoteException
org.apache.hadoop.yarn.api.ApplicationClientProtocol.renewDelegationToken()
Renew an existing delegation {@link Token}. @param request the delegation token to be renewed. @return the new expiry time for the delegation token. @throws YarnException @throws IOException
org.apache.hadoop.yarn.api.ClientRMProtocol.renewDelegationToken()
Renew an existing delegation token. @param request the delegation token to be renewed. @return the new expiry time for the delegation token. @throws YarnRemoteException

Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.renewDelegationToken()

    public long renew(Token<?> token, Configuration conf) throws IOException {
      Token<DelegationTokenIdentifier> delToken = 
        (Token<DelegationTokenIdentifier>) token;
      ClientProtocol nn = getNNProxy(delToken, conf);
      try {
        return nn.renewDelegationToken(delToken);
      } catch (RemoteException re) {
        throw re.unwrapRemoteException(InvalidToken.class, 
                                       AccessControlException.class);
      }
    }

View Full Code Here

Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.renewDelegationToken()

      ClientProtocol nn = 
        DFSUtil.createRPCNamenode
           (SecurityUtil.getTokenServiceAddr(delToken),
            conf, UserGroupInformation.getCurrentUser());
      try {
        return nn.renewDelegationToken(delToken);
      } catch (RemoteException re) {
        throw re.unwrapRemoteException(InvalidToken.class, 
                                       AccessControlException.class);
      }
    }

View Full Code Here

Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.renewDelegationToken()

    public long renew(Token<?> token, Configuration conf) throws IOException {
      Token<DelegationTokenIdentifier> delToken = 
        (Token<DelegationTokenIdentifier>) token;
      ClientProtocol nn = getNNProxy(delToken, conf);
      try {
        return nn.renewDelegationToken(delToken);
      } catch (RemoteException re) {
        throw re.unwrapRemoteException(InvalidToken.class, 
                                       AccessControlException.class);
      }
    }

View Full Code Here

Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.renewDelegationToken()

    public long renew(Token<?> token, Configuration conf) throws IOException {
      Token<DelegationTokenIdentifier> delToken = 
        (Token<DelegationTokenIdentifier>) token;
      ClientProtocol nn = getNNProxy(delToken, conf);
      try {
        return nn.renewDelegationToken(delToken);
      } catch (RemoteException re) {
        throw re.unwrapRemoteException(InvalidToken.class, 
                                       AccessControlException.class);
      }
    }

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.FSNamesystem.renewDelegationToken()

    ugi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws Exception {
        try {
          Token<DelegationTokenIdentifier> token = namesys
              .getDelegationToken(new Text(ugi.getShortUserName()));
          namesys.renewDelegationToken(token);
          namesys.cancelDelegationToken(token);
        } catch (IOException e) {
          e.printStackTrace();
          throw e;
        }

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.FSNamesystem.renewDelegationToken()

    final Token<DelegationTokenIdentifier> token = generateDelegationToken(
        "owner", ugi.getShortUserName());
    ugi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws Exception {
        try {
          namesys.renewDelegationToken(token);
          Assert
              .fail("Delegation token should not be renewed without Kerberos authentication");
        } catch (IOException e) {
          // success
        }

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.NameNode.renewDelegationToken()

    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = namenode.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.namenode.NameNode.renewDelegationToken()

    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = namenode.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.