org.apache.hadoop.mapreduce.v2.security

Class MRDelegationTokenRenewer

java.lang.Object

org.apache.hadoop.security.token.TokenRenewer

org.apache.hadoop.mapreduce.v2.security.MRDelegationTokenRenewer

@InterfaceAudience.Private
public class MRDelegationTokenRenewer
extends TokenRenewer

Constructor Summary

Constructors

Constructor and Description
MRDelegationTokenRenewer()

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel(Token<?> token, Configuration conf) Cancel the given token
boolean	handleKind(Text kind) Does this renewer handle this kind of token?
protected MRClientProtocol	instantiateHistoryProxy(Configuration conf, InetSocketAddress hsAddress)
boolean	isManaged(Token<?> token) Is the given token managed? Only managed tokens may be renewed or cancelled.
long	renew(Token<?> token, Configuration conf) Renew the given token.
protected void	stopHistoryProxy(MRClientProtocol proxy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MRDelegationTokenRenewer

public MRDelegationTokenRenewer()

Method Detail

handleKind

public boolean handleKind(Text kind)

Description copied from class: TokenRenewer

Does this renewer handle this kind of token?

Specified by:

handleKind in class TokenRenewer

Parameters:

kind - the kind of the token

Returns:

true if this renewer can renew it

renew

public long renew(Token<?> token,
         Configuration conf)
           throws IOException,
                  InterruptedException

Description copied from class: TokenRenewer

Renew the given token.

Specified by:

renew in class TokenRenewer

Returns:

the new expiration time

Throws:

IOException

InterruptedException

cancel

public void cancel(Token<?> token,
          Configuration conf)
            throws IOException,
                   InterruptedException

Description copied from class: TokenRenewer

Cancel the given token

Specified by:

cancel in class TokenRenewer

Throws:

IOException

InterruptedException

isManaged

public boolean isManaged(Token<?> token)
                  throws IOException

Description copied from class: TokenRenewer

Is the given token managed? Only managed tokens may be renewed or cancelled.

Specified by:

isManaged in class TokenRenewer

Parameters:

token - the token being checked

Returns:

true if the token may be renewed or cancelled

Throws:

IOException

stopHistoryProxy

protected void stopHistoryProxy(MRClientProtocol proxy)

instantiateHistoryProxy

protected MRClientProtocol instantiateHistoryProxy(Configuration conf,
                                       InetSocketAddress hsAddress)
                                            throws IOException

Throws:

IOException