public class KerberosDelegationTokenManager extends Object implements DelegationTokenManager
When delegation token renewal is enabled, this manager will make sure long-running apps can run without interruption while accessing secured services. It periodically logs in to the KDC with user-provided credentials, and contacts all the configured secure services to obtain delegation tokens to be distributed to the rest of the application.
Constructor and Description |
---|
KerberosDelegationTokenManager(Configuration configuration,
ScheduledExecutor scheduledExecutor,
ExecutorService ioExecutor) |
KerberosDelegationTokenManager(Configuration configuration,
ScheduledExecutor scheduledExecutor,
ExecutorService ioExecutor,
KerberosLoginProvider kerberosLoginProvider) |
Modifier and Type | Method and Description |
---|---|
void |
obtainDelegationTokens(org.apache.hadoop.security.Credentials credentials)
Obtains new tokens in a one-time fashion and leaves it up to the caller to distribute them.
|
protected Optional<Long> |
obtainDelegationTokensAndGetNextRenewal(org.apache.hadoop.security.Credentials credentials) |
void |
start()
Creates a re-occurring task which obtains new tokens and automatically distributes them to
task managers.
|
void |
stop()
Stops re-occurring token obtain task.
|
public KerberosDelegationTokenManager(Configuration configuration, @Nullable ScheduledExecutor scheduledExecutor, @Nullable ExecutorService ioExecutor)
public KerberosDelegationTokenManager(Configuration configuration, @Nullable ScheduledExecutor scheduledExecutor, @Nullable ExecutorService ioExecutor, KerberosLoginProvider kerberosLoginProvider)
public void obtainDelegationTokens(org.apache.hadoop.security.Credentials credentials) throws Exception
obtainDelegationTokens
in interface DelegationTokenManager
Exception
protected Optional<Long> obtainDelegationTokensAndGetNextRenewal(org.apache.hadoop.security.Credentials credentials)
public void start() throws Exception
start
in interface DelegationTokenManager
Exception
public void stop()
stop
in interface DelegationTokenManager
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.