Package org.apache.spark.scheduler

Interface SupportsDelegationToken

public interface SupportsDelegationToken
A mix-in trait for SchedulerBackend that supports delegation tokens.

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.Option<org.apache.spark.deploy.security.HadoopDelegationTokenManager>
    createTokenManager()
    Create the delegation token manager to be used for the application.
    scala.Option<org.apache.spark.deploy.security.HadoopDelegationTokenManager>
    delegationTokenManager()
     
    void
    setupTokenManager()
     
    void
    stopTokenManager()
     
    void
    updateDelegationTokens(byte[] tokens)
    Called when a new set of delegation tokens is sent to the driver.

  • Method Details

    • createTokenManager

      scala.Option<org.apache.spark.deploy.security.HadoopDelegationTokenManager> createTokenManager()
      Create the delegation token manager to be used for the application. This method is called once during the start of the scheduler backend (so after the object has already been fully constructed), only if security is enabled in the Hadoop configuration.
      Returns:
      (undocumented)

    • delegationTokenManager

      scala.Option<org.apache.spark.deploy.security.HadoopDelegationTokenManager> delegationTokenManager()

    • setupTokenManager

      void setupTokenManager()

    • stopTokenManager

      void stopTokenManager()

    • updateDelegationTokens

      void updateDelegationTokens(byte[] tokens)
      Called when a new set of delegation tokens is sent to the driver.
      Parameters:
      tokens - (undocumented)