| Constructor and Description |
|---|
HadoopUser(UserGroupInformation ugi,
Settings providerSettings) |
| Modifier and Type | Method and Description |
|---|---|
void |
addEsToken(EsToken esToken)
Adds the given esToken to the user
|
<T> T |
doAs(PrivilegedAction<T> action)
Execute the given action as the user
|
<T> T |
doAs(PrivilegedExceptionAction<T> action)
Execute the given action as the user
|
Iterable<EsToken> |
getAllEsTokens() |
EsToken |
getEsToken(String clusterName) |
KerberosPrincipal |
getKerberosPrincipal() |
UserProvider |
getRealUserProvider() |
String |
getUserName() |
boolean |
isProxyUser() |
String |
toString() |
public HadoopUser(UserGroupInformation ugi, Settings providerSettings)
public <T> T doAs(PrivilegedAction<T> action)
Userpublic <T> T doAs(PrivilegedExceptionAction<T> action) throws EsHadoopException
UserdoAs in interface UserT - The return type from the actionaction - To executeEsHadoopException - Should an exception be thrown during the operationpublic EsToken getEsToken(String clusterName)
getEsToken in interface UserclusterName - The cluster namepublic Iterable<EsToken> getAllEsTokens()
getAllEsTokens in interface Userpublic void addEsToken(EsToken esToken)
UseraddEsToken in interface UseresToken - Authentication token for Elasticsearchpublic String getUserName()
getUserName in interface Userpublic KerberosPrincipal getKerberosPrincipal()
getKerberosPrincipal in interface Userpublic boolean isProxyUser()
isProxyUser in interface Userpublic UserProvider getRealUserProvider()
getRealUserProvider in interface User