Package org.apache.flink.fs.s3.common.token

Class AbstractS3DelegationTokenReceiver

java.lang.Object

org.apache.flink.fs.s3.common.token.AbstractS3DelegationTokenReceiver

All Implemented Interfaces:

DelegationTokenReceiver

Direct Known Subclasses:

S3HadoopDelegationTokenReceiver, S3PrestoDelegationTokenReceiver

@Internal
public abstract class AbstractS3DelegationTokenReceiver
extends Object
implements DelegationTokenReceiver

Delegation token receiver for S3 filesystems.

Field Summary

Fields

Modifier and Type	Field	Description
static String	PROVIDER_CONFIG_NAME

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

CONFIG_PREFIX

Constructor Summary

Constructors

Constructor	Description
AbstractS3DelegationTokenReceiver()

Method Summary

Modifier and Type	Method	Description
static com.amazonaws.services.securitytoken.model.Credentials	getCredentials()
void	init(Configuration configuration)	Called to initialize receiver after construction.
void	onNewTokensObtained(byte[] tokens)	Callback function when new delegation tokens obtained.
static void	updateHadoopConfig(org.apache.hadoop.conf.Configuration hadoopConfig)

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

serviceConfigPrefix, serviceName

Field Detail

PROVIDER_CONFIG_NAME

public static final String PROVIDER_CONFIG_NAME

See Also:

Constant Field Values

Constructor Detail

AbstractS3DelegationTokenReceiver

public AbstractS3DelegationTokenReceiver()

Method Detail

updateHadoopConfig

public static void updateHadoopConfig(org.apache.hadoop.conf.Configuration hadoopConfig)

init

public void init(Configuration configuration)

Description copied from interface: DelegationTokenReceiver

Called to initialize receiver after construction.

Specified by:

init in interface DelegationTokenReceiver

Parameters:

configuration - Configuration to initialize the receiver.

onNewTokensObtained

public void onNewTokensObtained(byte[] tokens)
                         throws Exception

Description copied from interface: DelegationTokenReceiver

Callback function when new delegation tokens obtained.

Specified by:

onNewTokensObtained in interface DelegationTokenReceiver

Parameters:

tokens - Serialized form of delegation tokens. Must be deserialized the reverse way which is implemented in DelegationTokenProvider.

Throws:

Exception

getCredentials

@Nullable
public static com.amazonaws.services.securitytoken.model.Credentials getCredentials()