Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
FileContext.getUgi()
Gets the ugi in the file-context
|
Modifier and Type | Method and Description |
---|---|
static void |
FileSystem.closeAllForUGI(UserGroupInformation ugi)
Close all cached filesystems for a given UGI.
|
Modifier and Type | Field and Description |
---|---|
protected UserGroupInformation |
HftpFileSystem.ugi |
Modifier and Type | Method and Description |
---|---|
static void |
HAUtil.cloneDelegationTokenForLogicalUri(UserGroupInformation ugi,
URI haUri,
Collection<InetSocketAddress> nnAddrs)
Locate a delegation token associated with the given HA cluster URI, and if
one is found, clone it to also represent the underlying namenode address.
|
static ClientDatanodeProtocol |
DFSUtil.createClientDatanodeProtocolProxy(InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory)
Create a
ClientDatanodeProtocol proxy |
static <T> NameNodeProxies.ProxyAndInfo<T> |
NameNodeProxies.createNonHAProxy(Configuration conf,
InetSocketAddress nnAddr,
Class<T> xface,
UserGroupInformation ugi,
boolean withRetries)
Creates an explicitly non-HA-enabled proxy object.
|
protected Token<DelegationTokenIdentifier> |
HftpFileSystem.selectDelegationToken(UserGroupInformation ugi) |
Constructor and Description |
---|
ClientDatanodeProtocolTranslatorPB(InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory) |
InterDatanodeProtocolTranslatorPB(InetSocketAddress addr,
UserGroupInformation ugi,
Configuration conf,
SocketFactory factory,
int socketTimeout) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
BlockTokenIdentifier.getUser() |
Modifier and Type | Method and Description |
---|---|
static Credentials |
DelegationTokenSecretManager.createCredentials(NameNode namenode,
UserGroupInformation ugi,
String renewer)
A utility method for creating credentials.
|
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
JspHelper.getDefaultWebUser(Configuration conf)
If security is turned off, what is the default web user?
|
static UserGroupInformation |
JspHelper.getUGI(javax.servlet.http.HttpServletRequest request,
Configuration conf)
Same as getUGI(null, request, conf).
|
static UserGroupInformation |
JspHelper.getUGI(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest request,
Configuration conf)
Same as getUGI(context, request, conf, KERBEROS_SSL, true).
|
static UserGroupInformation |
JspHelper.getUGI(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest request,
Configuration conf,
UserGroupInformation.AuthenticationMethod secureAuthMethod,
boolean tryUgiParameter)
Get
UserGroupInformation and possibly the delegation token out of
the request. |
Modifier and Type | Method and Description |
---|---|
static DFSClient |
DatanodeJspHelper.getDFSClient(javax.servlet.http.HttpServletRequest request,
DataNode datanode,
Configuration conf,
UserGroupInformation ugi)
Get DFSClient for a namenode corresponding to the BPID from a datanode
|
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.get(UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
UriFsPathParam path,
GetOpParam op,
OffsetParam offset,
LengthParam length,
BufferSizeParam bufferSize)
Handle HTTP GET request.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.getRoot(UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
GetOpParam op,
OffsetParam offset,
LengthParam length,
BufferSizeParam bufferSize)
Handle HTTP GET request for the root.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.post(InputStream in,
UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
UriFsPathParam path,
PostOpParam op,
BufferSizeParam bufferSize)
Handle HTTP POST request.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.postRoot(InputStream in,
UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
PostOpParam op,
BufferSizeParam bufferSize)
Handle HTTP POST request for the root for the root.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.put(InputStream in,
UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
UriFsPathParam path,
PutOpParam op,
PermissionParam permission,
OverwriteParam overwrite,
BufferSizeParam bufferSize,
ReplicationParam replication,
BlockSizeParam blockSize)
Handle HTTP PUT request.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.putRoot(InputStream in,
UserGroupInformation ugi,
DelegationParam delegation,
NamenodeRpcAddressParam namenodeRpcAddress,
PutOpParam op,
PermissionParam permission,
OverwriteParam overwrite,
BufferSizeParam bufferSize,
ReplicationParam replication,
BlockSizeParam blockSize)
Handle HTTP PUT request for the root.
|
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
NameNode.getRemoteUser() |
Modifier and Type | Method and Description |
---|---|
abstract void |
HdfsAuditLogger.logAuditEvent(boolean succeeded,
String userName,
InetAddress addr,
String cmd,
String src,
String dst,
FileStatus stat,
UserGroupInformation ugi,
DelegationTokenSecretManager dtSecretManager)
Same as
HdfsAuditLogger.logAuditEvent(boolean, String, InetAddress, String, String, String, FileStatus)
with additional parameters related to logging delegation token tracking
IDs. |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.delete(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
UriFsPathParam path,
DeleteOpParam op,
RecursiveParam recursive)
Handle HTTP DELETE request.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.deleteRoot(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
DeleteOpParam op,
RecursiveParam recursive)
Handle HTTP DELETE request for the root.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.get(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
UriFsPathParam path,
GetOpParam op,
OffsetParam offset,
LengthParam length,
RenewerParam renewer,
BufferSizeParam bufferSize)
Handle HTTP GET request.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.getRoot(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
GetOpParam op,
OffsetParam offset,
LengthParam length,
RenewerParam renewer,
BufferSizeParam bufferSize)
Handle HTTP GET request for the root.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.post(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
UriFsPathParam path,
PostOpParam op,
ConcatSourcesParam concatSrcs,
BufferSizeParam bufferSize)
Handle HTTP POST request.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.postRoot(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
PostOpParam op,
ConcatSourcesParam concatSrcs,
BufferSizeParam bufferSize)
Handle HTTP POST request for the root.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.put(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
UriFsPathParam path,
PutOpParam op,
DestinationParam destination,
OwnerParam owner,
GroupParam group,
PermissionParam permission,
OverwriteParam overwrite,
BufferSizeParam bufferSize,
ReplicationParam replication,
BlockSizeParam blockSize,
ModificationTimeParam modificationTime,
AccessTimeParam accessTime,
RenameOptionSetParam renameOptions,
CreateParentParam createParent,
TokenArgumentParam delegationTokenArgument)
Handle HTTP PUT request.
|
javax.ws.rs.core.Response |
NamenodeWebHdfsMethods.putRoot(UserGroupInformation ugi,
DelegationParam delegation,
UserParam username,
DoAsParam doAsUser,
PutOpParam op,
DestinationParam destination,
OwnerParam owner,
GroupParam group,
PermissionParam permission,
OverwriteParam overwrite,
BufferSizeParam bufferSize,
ReplicationParam replication,
BlockSizeParam blockSize,
ModificationTimeParam modificationTime,
AccessTimeParam accessTime,
RenameOptionSetParam renameOptions,
CreateParentParam createParent,
TokenArgumentParam delegationTokenArgument)
Handle HTTP PUT request for the root.
|
Modifier and Type | Method and Description |
---|---|
static String |
WebHdfsFileSystem.getHomeDirectoryString(UserGroupInformation ugi) |
protected Token<DelegationTokenIdentifier> |
WebHdfsFileSystem.selectDelegationToken(UserGroupInformation ugi) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
UserProvider.getValue(com.sun.jersey.api.core.HttpContext context) |
Modifier and Type | Method and Description |
---|---|
com.sun.jersey.spi.inject.Injectable<UserGroupInformation> |
UserProvider.getInjectable(com.sun.jersey.core.spi.component.ComponentContext componentContext,
javax.ws.rs.core.Context context,
Type type) |
Constructor and Description |
---|
UserParam(UserGroupInformation ugi)
Construct an object from a UGI.
|
Modifier and Type | Field and Description |
---|---|
UserGroupInformation |
Server.Connection.attemptingUser |
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
Server.getRemoteUser()
Returns the RPC remote user when invoked inside an RPC.
|
Modifier and Type | Method and Description |
---|---|
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout)
Deprecated.
Use
Client.call(RPC.RpcKind, Writable,
ConnectionId) instead |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout,
Configuration conf)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, rpcTimeout as
timeout and conf as conf for this connection, returning the
value. |
Writable |
Client.call(RPC.RpcKind rpcKind,
Writable param,
InetSocketAddress addr,
UserGroupInformation ticket)
Deprecated.
Use
Client.call(RPC.RpcKind, Writable,
ConnectionId) instead |
Writable |
Client.call(Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout,
Configuration conf)
Same as
Client.call(RPC.RpcKind, Writable, InetSocketAddress,
Class, UserGroupInformation, int, Configuration)
except that rpcKind is writable. |
Writable |
Client.call(Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout,
int serviceClass,
Configuration conf)
Same as
Client.call(Writable, InetSocketAddress,
Class, UserGroupInformation, int, Configuration)
except that specifying serviceClass. |
static <T> ProtocolProxy<T> |
RPC.getProtocolProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory)
Get a protocol proxy that contains a proxy connection to a remote server
and a set of methods that are supported by the server
|
static <T> ProtocolProxy<T> |
RPC.getProtocolProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Get a protocol proxy that contains a proxy connection to a remote server
and a set of methods that are supported by the server
|
static <T> T |
RPC.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout) |
static <T> T |
RPC.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout)
Construct a client-side proxy that implements the named protocol,
talking to a server at the named address.
|
<T> ProtocolProxy<T> |
WritableRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy) |
<T> ProtocolProxy<T> |
RpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object.
|
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
DelegationTokenManager.verifyToken(Token<DelegationTokenIdentifier> token)
Verifies a delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenManager.createToken(UserGroupInformation ugi,
String renewer)
Creates a delegation token.
|
Modifier and Type | Method and Description |
---|---|
protected UserGroupInformation |
FileSystemAccessService.getUGI(String user) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
DelegationTokenManagerService.verifyToken(Token<DelegationTokenIdentifier> token)
Verifies a delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenManagerService.createToken(UserGroupInformation ugi,
String renewer)
Creates a delegation token.
|
Modifier and Type | Method and Description |
---|---|
boolean |
JobACLsManager.checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation,
String jobOwner,
AccessControlList jobACL)
If authorization is enabled, checks whether the user (in the callerUGI)
is authorized to perform the operation specified by 'jobOperation' on
the job by checking if the user is jobOwner or part of job ACL for the
specific job operation.
|
boolean |
QueueManager.hasAccess(String queueName,
QueueACL qACL,
UserGroupInformation ugi)
Return true if the given user is part of the ACL for the given
QueueACL name for the given queue. |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
SubmitterUserResolver.getTargetUgi(UserGroupInformation ugi) |
UserGroupInformation |
UserResolver.getTargetUgi(UserGroupInformation ugi)
Map the given UGI to another per the subclass contract.
|
UserGroupInformation |
EchoUserResolver.getTargetUgi(UserGroupInformation ugi) |
UserGroupInformation |
RoundRobinUserResolver.getTargetUgi(UserGroupInformation ugi) |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.hadoop.mapred.gridmix.GridmixJob |
JobCreator.createGridmixJob(Configuration conf,
long submissionMillis,
JobStory jobdesc,
Path outRoot,
UserGroupInformation ugi,
int seq)
Create Gridmix simulated job.
|
UserGroupInformation |
SubmitterUserResolver.getTargetUgi(UserGroupInformation ugi) |
UserGroupInformation |
UserResolver.getTargetUgi(UserGroupInformation ugi)
Map the given UGI to another per the subclass contract.
|
UserGroupInformation |
EchoUserResolver.getTargetUgi(UserGroupInformation ugi) |
UserGroupInformation |
RoundRobinUserResolver.getTargetUgi(UserGroupInformation ugi) |
Constructor and Description |
---|
SleepJob(Configuration conf,
long submissionMillis,
JobStory jobdesc,
Path outRoot,
UserGroupInformation ugi,
int seq,
int numLocations,
String[] hosts) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
JobTokenIdentifier.getUser()
Get the Ugi with the username encoded in the token identifier
|
Modifier and Type | Field and Description |
---|---|
protected UserGroupInformation |
JobContextImpl.ugi
The UserGroupInformation object that has a reference to the current user
|
Modifier and Type | Field and Description |
---|---|
protected UserGroupInformation |
MRAppMaster.currentUser |
Modifier and Type | Method and Description |
---|---|
boolean |
Job.checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation) |
Modifier and Type | Method and Description |
---|---|
boolean |
JobImpl.checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation) |
Modifier and Type | Method and Description |
---|---|
boolean |
CompletedJob.checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation) |
boolean |
PartialJob.checkAccess(UserGroupInformation callerUGI,
JobACL jobOperation) |
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
UserGroupInformation.createProxyUser(String user,
UserGroupInformation realUser)
Create a proxy user using username of the effective user and the ugi of the
real user.
|
static UserGroupInformation |
UserGroupInformation.createProxyUserForTesting(String user,
UserGroupInformation realUser,
String[] userGroups)
Create a proxy user UGI for testing HDFS and MapReduce
|
static UserGroupInformation |
UserGroupInformation.createRemoteUser(String user)
Create a user from a login name.
|
static UserGroupInformation |
UserGroupInformation.createUserForTesting(String user,
String[] userGroups)
Create a UGI for testing HDFS and MapReduce
|
static UserGroupInformation |
UserGroupInformation.getBestUGI(String ticketCachePath,
String user)
Find the most appropriate UserGroupInformation to use
|
static UserGroupInformation |
UserGroupInformation.getCurrentUser()
Return the current user, including any doAs in the current stack.
|
static UserGroupInformation |
UserGroupInformation.getLoginUser()
Get the currently logged in user.
|
UserGroupInformation |
UserGroupInformation.getRealUser()
get RealUser (vs.
|
static UserGroupInformation |
UserGroupInformation.getUGIFromTicketCache(String ticketCache,
String user)
Create a UserGroupInformation from a Kerberos ticket cache.
|
static UserGroupInformation |
UserGroupInformation.loginUserFromKeytabAndReturnUGI(String user,
String path)
Log a user in from a keytab file.
|
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
UserGroupInformation.createProxyUser(String user,
UserGroupInformation realUser)
Create a proxy user using username of the effective user and the ugi of the
real user.
|
static UserGroupInformation |
UserGroupInformation.createProxyUserForTesting(String user,
UserGroupInformation realUser,
String[] userGroups)
Create a proxy user UGI for testing HDFS and MapReduce
|
static UserGroupInformation.AuthenticationMethod |
UserGroupInformation.getRealAuthenticationMethod(UserGroupInformation ugi)
Returns the authentication method of a ugi.
|
static void |
UserGroupInformation.setLoginUser(UserGroupInformation ugi) |
Constructor and Description |
---|
SaslRpcClient(UserGroupInformation ugi,
Class<?> protocol,
InetSocketAddress serverAddr,
Configuration conf)
Create a SaslRpcClient that can be used by a RPC client to negotiate
SASL authentication with a RPC server
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceAuthorizationManager.authorize(UserGroupInformation user,
Class<?> protocol,
Configuration conf,
InetAddress addr)
Authorize the user to access the protocol being used.
|
static void |
ProxyUsers.authorize(UserGroupInformation user,
String remoteAddress,
Configuration newConf)
Authorize the superuser which is doing doAs
|
boolean |
AccessControlList.isUserAllowed(UserGroupInformation ugi) |
Modifier and Type | Method and Description |
---|---|
abstract UserGroupInformation |
TokenIdentifier.getUser()
Get the Ugi with the username encoded in the token identifier
|
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
AbstractDelegationTokenIdentifier.getUser()
Get the username encoded in the token identifier
|
Modifier and Type | Method and Description |
---|---|
static UserGroupInformation |
ProtoUtil.getUgi(IpcConnectionContextProtos.IpcConnectionContextProto context) |
static UserGroupInformation |
ProtoUtil.getUgi(IpcConnectionContextProtos.UserInformationProto userInfo) |
Modifier and Type | Method and Description |
---|---|
static IpcConnectionContextProtos.IpcConnectionContextProto |
ProtoUtil.makeIpcConnectionContext(String protocol,
UserGroupInformation ugi,
SaslRpcServer.AuthMethod authMethod)
This method creates the connection context using exactly the same logic
as the old connection context as was done for writable where
the effective and real users are set based on the auth method.
|
Constructor and Description |
---|
AggregatedLogFormat.LogWriter(Configuration conf,
Path remoteAppLogFile,
UserGroupInformation userUgi) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
AdminACLsManager.getOwner()
Returns the owner
|
UserGroupInformation |
NMTokenIdentifier.getUser() |
UserGroupInformation |
ContainerTokenIdentifier.getUser() |
UserGroupInformation |
AMRMTokenIdentifier.getUser() |
Modifier and Type | Method and Description |
---|---|
boolean |
AdminACLsManager.checkAccess(UserGroupInformation callerUGI)
Returns whether the specified user/group has administrator access
|
boolean |
AdminACLsManager.isAdmin(UserGroupInformation callerUGI)
Returns whether the specified user/group is an administrator
|
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
ClientToAMTokenIdentifier.getUser() |
Modifier and Type | Method and Description |
---|---|
protected UserGroupInformation |
ContainerManagerImpl.getRemoteUgi() |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerManagerImpl.authorizeUser(UserGroupInformation remoteUgi,
NMTokenIdentifier nmTokenIdentifier) |
protected NMTokenIdentifier |
ContainerManagerImpl.selectNMTokenIdentifier(UserGroupInformation remoteUgi) |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerLocalizer.closeFileSystems(UserGroupInformation ugi) |
protected void |
ContainerLocalizer.localizeFiles(LocalizationProtocol nodemanager,
CompletionService<Path> cs,
UserGroupInformation ugi) |
Modifier and Type | Method and Description |
---|---|
UserGroupInformation |
LocalizerTokenIdentifier.getUser() |
Modifier and Type | Method and Description |
---|---|
protected void |
LogAggregationService.closeFileSystems(UserGroupInformation userUgi) |
protected void |
LogAggregationService.createAppDir(String user,
ApplicationId appId,
UserGroupInformation userUgi) |
Constructor and Description |
---|
AppLogAggregatorImpl(Dispatcher dispatcher,
DeletionService deletionService,
Configuration conf,
ApplicationId appId,
UserGroupInformation userUgi,
LocalDirsHandlerService dirsHandler,
Path remoteNodeLogFileForApp,
ContainerLogsRetentionPolicy retentionPolicy,
Map<ApplicationAccessType,String> appAcls) |
Modifier and Type | Method and Description |
---|---|
boolean |
YarnScheduler.checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName)
Check if the user has permission to perform the operation.
|
List<QueueUserACLInfo> |
Queue.getQueueUserAclInfo(UserGroupInformation user)
Get queue ACLs for given
user . |
boolean |
Queue.hasAccess(QueueACL acl,
UserGroupInformation user) |
Modifier and Type | Method and Description |
---|---|
boolean |
CapacityScheduler.checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName) |
List<QueueUserACLInfo> |
ParentQueue.getQueueUserAclInfo(UserGroupInformation user) |
List<QueueUserACLInfo> |
LeafQueue.getQueueUserAclInfo(UserGroupInformation user) |
boolean |
ParentQueue.hasAccess(QueueACL acl,
UserGroupInformation user) |
boolean |
CSQueue.hasAccess(QueueACL acl,
UserGroupInformation user)
Check if the
user has permission to perform the operation |
boolean |
LeafQueue.hasAccess(QueueACL acl,
UserGroupInformation user) |
Modifier and Type | Method and Description |
---|---|
boolean |
FairScheduler.checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName) |
List<QueueUserACLInfo> |
FSLeafQueue.getQueueUserAclInfo(UserGroupInformation user) |
List<QueueUserACLInfo> |
FSParentQueue.getQueueUserAclInfo(UserGroupInformation user) |
boolean |
FSQueue.hasAccess(QueueACL acl,
UserGroupInformation user) |
Modifier and Type | Method and Description |
---|---|
boolean |
FifoScheduler.checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName) |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueACLsManager.checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName) |
Modifier and Type | Method and Description |
---|---|
boolean |
ApplicationACLsManager.checkAccess(UserGroupInformation callerUGI,
ApplicationAccessType applicationAccessType,
String applicationOwner,
ApplicationId applicationId)
If authorization is enabled, checks whether the user (in the callerUGI) is
authorized to perform the access specified by 'applicationAccessType' on
the application by checking if the user is applicationOwner or part of
application ACL for the specific access-type.
|
Constructor and Description |
---|
FSDownload(FileContext files,
UserGroupInformation ugi,
Configuration conf,
Path destDirPath,
LocalResource resource) |
Copyright © 2013 Apache Software Foundation. All rights reserved.