org.apache.spark.security

Interface HadoopDelegationTokenProvider

public interface HadoopDelegationTokenProvider

::DeveloperApi:: Hadoop delegation token provider.

Method Summary

Modifier and Type	Method and Description
boolean	delegationTokensRequired(SparkConf sparkConf, org.apache.hadoop.conf.Configuration hadoopConf) Returns true if delegation tokens are required for this service.
scala.Option<Object>	obtainDelegationTokens(org.apache.hadoop.conf.Configuration hadoopConf, SparkConf sparkConf, org.apache.hadoop.security.Credentials creds) Obtain delegation tokens for this service and get the time of the next renewal.
String	serviceName() Name of the service to provide delegation tokens.

Method Detail

delegationTokensRequired

boolean delegationTokensRequired(SparkConf sparkConf,
                                 org.apache.hadoop.conf.Configuration hadoopConf)

Returns true if delegation tokens are required for this service. By default, it is based on whether Hadoop security is enabled.

Parameters:

sparkConf - (undocumented)

hadoopConf - (undocumented)

Returns:

(undocumented)

obtainDelegationTokens

scala.Option<Object> obtainDelegationTokens(org.apache.hadoop.conf.Configuration hadoopConf,
                                            SparkConf sparkConf,
                                            org.apache.hadoop.security.Credentials creds)

Obtain delegation tokens for this service and get the time of the next renewal.

Parameters:

hadoopConf - Configuration of current Hadoop Compatible system.

creds - Credentials to add tokens and security keys to.

sparkConf - (undocumented)

Returns:

If the returned tokens are renewable and can be renewed, return the time of the next renewal, otherwise None should be returned.

serviceName

String serviceName()

Name of the service to provide delegation tokens. This name should be unique. Spark will internally use this name to differentiate delegation token providers.

Returns:

(undocumented)