trait HadoopDelegationTokenProvider extends AnyRef
::DeveloperApi:: Hadoop delegation token provider.
- Annotations
- @DeveloperApi()
- Source
- HadoopDelegationTokenProvider.scala
- Alphabetic
- By Inheritance
- HadoopDelegationTokenProvider
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
delegationTokensRequired(sparkConf: SparkConf, hadoopConf: Configuration): Boolean
Returns true if delegation tokens are required for this service.
Returns true if delegation tokens are required for this service. By default, it is based on whether Hadoop security is enabled.
-
abstract
def
obtainDelegationTokens(hadoopConf: Configuration, sparkConf: SparkConf, creds: Credentials): Option[Long]
Obtain delegation tokens for this service and get the time of the next renewal.
Obtain delegation tokens for this service and get the time of the next renewal.
- hadoopConf
Configuration of current Hadoop Compatible system.
- creds
Credentials to add tokens and security keys to.
- returns
If the returned tokens are renewable and can be renewed, return the time of the next renewal, otherwise None should be returned.
-
abstract
def
serviceName: String
Name of the service to provide delegation tokens.
Name of the service to provide delegation tokens. This name should be unique. Spark will internally use this name to differentiate delegation token providers.