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

Class HadoopFSDelegationTokenReceiver

java.lang.Object

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

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

All Implemented Interfaces:

DelegationTokenReceiver

@Internal
public class HadoopFSDelegationTokenReceiver
extends HadoopDelegationTokenReceiver

Delegation token receiver for Hadoop filesystems.

Field Summary

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

CONFIG_PREFIX

Constructor Summary

Constructors

Constructor and Description
HadoopFSDelegationTokenReceiver()

Method Summary

Modifier and Type	Method and Description
String	serviceName() Name of the service to receive delegation tokens for.

Methods inherited from class org.apache.flink.runtime.security.token.hadoop.HadoopDelegationTokenReceiver

init, onNewTokensObtained

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

Constructor Detail

HadoopFSDelegationTokenReceiver

public HadoopFSDelegationTokenReceiver()

Method Detail

serviceName

public String serviceName()

Description copied from interface: DelegationTokenReceiver

Name of the service to receive delegation tokens for. This name should be unique and the same as the one provided in the corresponding DelegationTokenProvider.

Specified by:

serviceName in interface DelegationTokenReceiver

Specified by:

serviceName in class HadoopDelegationTokenReceiver