Package org.apache.storm.common
Class AbstractHadoopAutoCreds
java.lang.Object
org.apache.storm.common.AbstractHadoopAutoCreds
- All Implemented Interfaces:
CredentialKeyProvider
,IAutoCredentials
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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected abstract void
Prepare the plugin.protected abstract String
The lookup key for the config key string.getCredentials
(Map<String, String> credentials) void
populateCredentials
(Map<String, String> credentials) Called to populate the credentials on the client side.void
populateSubject
(Subject subject, Map<String, String> credentials) Called to initially populate the subject on the worker side with credentials passed in.void
void
updateSubject
(Subject subject, Map<String, String> credentials) Called to update the subject on the worker side when new credentials are recieved.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.storm.common.CredentialKeyProvider
getCredentialKey
-
Constructor Details
-
AbstractHadoopAutoCreds
public AbstractHadoopAutoCreds()
-
-
Method Details
-
prepare
- Specified by:
prepare
in interfaceIAutoCredentials
-
populateCredentials
Description copied from interface:IAutoCredentials
Called to populate the credentials on the client side.- Specified by:
populateCredentials
in interfaceIAutoCredentials
- Parameters:
credentials
- the credentials to be populated.
-
populateSubject
Called to initially populate the subject on the worker side with credentials passed in.- Specified by:
populateSubject
in interfaceIAutoCredentials
- Parameters:
subject
- the subject to optionally put credentials in.credentials
- the credentials to be used.
-
updateSubject
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 interfaceIAutoCredentials
- Parameters:
subject
- the subject to optionally put credentials in.credentials
- the credentials to be used.
-
getCredentials
-
doPrepare
Prepare the plugin.- Parameters:
topoConf
- the topology conf
-
getConfigKeyString
The lookup key for the config key string.- Returns:
- the config key string
-