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.DistributedFileSystem.renewDelegationToken()

    });
    shortUgi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws IOException {
        final DistributedFileSystem dfs = (DistributedFileSystem) cluster
            .getFileSystem();
        dfs.renewDelegationToken(token);
        return null;
      }
    });
    longUgi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws IOException {

View Full Code Here

Examples of org.apache.hadoop.hdfs.DistributedFileSystem.renewDelegationToken()

      public Object run() throws IOException {
        final DistributedFileSystem dfs = (DistributedFileSystem) cluster
            .getFileSystem();
        try {
          //try renew with long name
          dfs.renewDelegationToken(token);
        } catch (IOException e) {
          Assert.fail("Could not renew delegation token for user "+longUgi);
        }
        return null;
      }

View Full Code Here

Examples of org.apache.hadoop.hdfs.DistributedFileSystem.renewDelegationToken()

    });
    shortUgi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws IOException {
        final DistributedFileSystem dfs = (DistributedFileSystem) cluster
            .getFileSystem();
        dfs.renewDelegationToken(token);
        return null;
      }
    });
    longUgi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws IOException {

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.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.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

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.