trait HadoopDelegationTokenProvider extends AnyRef
::DeveloperApi:: Hadoop delegation token provider.
- Annotations
- @DeveloperApi()
- 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.
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()