org.apache.flink.runtime.security.token.hadoop

Class HBaseDelegationTokenProvider

java.lang.Object

org.apache.flink.runtime.security.token.hadoop.HBaseDelegationTokenProvider

All Implemented Interfaces:

DelegationTokenProvider

@Internal
public class HBaseDelegationTokenProvider
extends Object
implements DelegationTokenProvider

Delegation token provider implementation for HBase. Basically it would be good to move this to flink-connector-hbase-base but HBase connection can be made without the connector. All in all I tend to move this but that would be a breaking change.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.core.security.token.DelegationTokenProvider

DelegationTokenProvider.ObtainedDelegationTokens

Field Summary

Fields inherited from interface org.apache.flink.core.security.token.DelegationTokenProvider

CONFIG_PREFIX

Constructor Summary

Constructors

Constructor and Description
HBaseDelegationTokenProvider()

Method Summary

Modifier and Type	Method and Description
boolean	delegationTokensRequired() Return whether delegation tokens are required for this service.
void	init(Configuration configuration) Called by DelegationTokenManager to initialize provider after construction.
DelegationTokenProvider.ObtainedDelegationTokens	obtainDelegationTokens() Obtain delegation tokens for this service.
String	serviceName() Name of the service to provide delegation tokens.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.core.security.token.DelegationTokenProvider

serviceConfigPrefix

Constructor Detail

HBaseDelegationTokenProvider

public HBaseDelegationTokenProvider()

Method Detail

serviceName

public String serviceName()

Description copied from interface: DelegationTokenProvider

Name of the service to provide delegation tokens. This name should be unique.

Specified by:

serviceName in interface DelegationTokenProvider

init

public void init(Configuration configuration)
          throws Exception

Description copied from interface: DelegationTokenProvider

Called by DelegationTokenManager to initialize provider after construction.

Specified by:

init in interface DelegationTokenProvider

Parameters:

configuration - Configuration to initialize the provider.

Throws:

Exception

delegationTokensRequired

public boolean delegationTokensRequired()
                                 throws Exception

Description copied from interface: DelegationTokenProvider

Return whether delegation tokens are required for this service.

Specified by:

delegationTokensRequired in interface DelegationTokenProvider

Returns:

true if delegation tokens are required.

Throws:

Exception

obtainDelegationTokens

public DelegationTokenProvider.ObtainedDelegationTokens obtainDelegationTokens()
                                                                        throws Exception

Description copied from interface: DelegationTokenProvider

Obtain delegation tokens for this service.

Specified by:

obtainDelegationTokens in interface DelegationTokenProvider

Returns:

the obtained delegation tokens.

Throws:

Exception