Package org.apache.storm.common

Class AbstractHadoopAutoCreds

java.lang.Object
org.apache.storm.common.AbstractHadoopAutoCreds
All Implemented Interfaces:
CredentialKeyProvider, IAutoCredentials
Direct Known Subclasses:
AutoHBase, AutoHDFS, AutoHive
public abstract class AbstractHadoopAutoCreds extends Object implements IAutoCredentials, CredentialKeyProvider
The base class that for auto credential plugins that abstracts out some of the common functionality.

  • Constructor Details

    • AbstractHadoopAutoCreds

      public AbstractHadoopAutoCreds()

  • Method Details

    • prepare

      public void prepare(Map<String,Object> topoConf)
      Specified by:
      prepare in interface IAutoCredentials

    • populateCredentials

      public void populateCredentials(Map<String,String> credentials)
      Description copied from interface: IAutoCredentials
      Called to populate the credentials on the client side.
      Specified by:
      populateCredentials in interface IAutoCredentials
      Parameters:
      credentials - the credentials to be populated.

    • populateSubject

      public void populateSubject(Subject subject, Map<String,String> credentials)
      Called to initially populate the subject on the worker side with credentials passed in.
      Specified by:
      populateSubject in interface IAutoCredentials
      Parameters:
      subject - the subject to optionally put credentials in.
      credentials - the credentials to be used.

    • updateSubject

      public void updateSubject(Subject subject, Map<String,String> credentials)
      Called to update the subject on the worker side when new credentials are recieved. This means that populateSubject has already been called on this subject.
      Specified by:
      updateSubject in interface IAutoCredentials
      Parameters:
      subject - the subject to optionally put credentials in.
      credentials - the credentials to be used.

    • getCredentials

      public Set<org.apache.commons.math3.util.Pair<String,org.apache.hadoop.security.Credentials>> getCredentials(Map<String,String> credentials)

    • doPrepare

      protected abstract void doPrepare(Map<String,Object> topoConf)
      Prepare the plugin.
      Parameters:
      topoConf - the topology conf

    • getConfigKeyString

      protected abstract String getConfigKeyString()
      The lookup key for the config key string.
      Returns:
      the config key string