Package org.apache.spark.security

Interface HadoopDelegationTokenProvider

public interface HadoopDelegationTokenProvider
::DeveloperApi:: Hadoop delegation token provider.

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • 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)