| 限定符和类型 | 方法和说明 |
|---|---|
static void |
FileSystem.closeAllForUGI(UserGroupInformation ugi)
Close all cached filesystems for a given UGI.
|
| 限定符和类型 | 字段和说明 |
|---|---|
protected UserGroupInformation |
HftpFileSystem.ugi |
| 限定符和类型 | 方法和说明 |
|---|---|
UserGroupInformation |
BlockTokenIdentifier.getUser() |
| 限定符和类型 | 方法和说明 |
|---|---|
static Credentials |
DelegationTokenSecretManager.createCredentials(NameNode namenode,
UserGroupInformation ugi,
String renewer)
A utility method for creating credentials.
|
static Token<DelegationTokenIdentifier> |
DelegationTokenSelector.selectHdfsDelegationToken(InetSocketAddress nnAddr,
UserGroupInformation ugi,
Configuration conf)
Select the delegation token for hdfs from the ugi.
|
| 限定符和类型 | 方法和说明 |
|---|---|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.get(UserGroupInformation ugi,
DelegationParam delegation,
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,
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,
UriFsPathParam path,
PostOpParam op,
BufferSizeParam bufferSize)
Handle HTTP POST request.
|
javax.ws.rs.core.Response |
DatanodeWebHdfsMethods.postRoot(InputStream in,
UserGroupInformation ugi,
DelegationParam delegation,
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,
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,
PutOpParam op,
PermissionParam permission,
OverwriteParam overwrite,
BufferSizeParam bufferSize,
ReplicationParam replication,
BlockSizeParam blockSize)
Handle HTTP PUT request for the root.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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)
Get
UserGroupInformation and possibly the delegation token out of
the request. |
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. |
| 限定符和类型 | 方法和说明 |
|---|---|
protected URI |
FileDataServlet.createUri(String parent,
HdfsFileStatus i,
UserGroupInformation ugi,
ClientProtocol nnproxy,
javax.servlet.http.HttpServletRequest request,
String dt)
Create a redirection URI
|
static DFSClient |
JspHelper.getDFSClient(UserGroupInformation user,
InetSocketAddress addr,
Configuration conf) |
| 限定符和类型 | 方法和说明 |
|---|---|
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,
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,
TokenArgumentParam delegationTokenArgument)
Handle HTTP PUT request for the root.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static String |
WebHdfsFileSystem.getHomeDirectoryString(UserGroupInformation ugi) |
| 限定符和类型 | 方法和说明 |
|---|---|
UserGroupInformation |
UserProvider.getValue(com.sun.jersey.api.core.HttpContext context) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 构造器和说明 |
|---|
UserParam(UserGroupInformation ugi)
Construct an object from a UGI.
|
| 限定符和类型 | 字段和说明 |
|---|---|
UserGroupInformation |
Server.Connection.attemptingUser |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
Server.authorize(UserGroupInformation user,
org.apache.hadoop.ipc.ConnectionHeader connection,
InetAddress addr)
Authorize the incoming client connection.
|
static Object[] |
RPC.call(Method method,
Object[][] params,
InetSocketAddress[] addrs,
UserGroupInformation ticket,
Configuration conf)
Expert: Make multiple, parallel calls to a set of servers.
|
Writable[] |
Client.call(Writable[] params,
InetSocketAddress[] addresses,
Class<?> protocol,
UserGroupInformation ticket)
|
Writable[] |
Client.call(Writable[] params,
InetSocketAddress[] addresses,
Class<?> protocol,
UserGroupInformation ticket,
Configuration conf)
Makes a set of calls in parallel.
|
Writable |
Client.call(Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket,
int rpcTimeout)
已过时。
Use
Client.call(Writable, ConnectionId) instead |
Writable |
Client.call(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 configuration for this connection, returning the
value. |
Writable |
Client.call(Writable param,
InetSocketAddress addr,
UserGroupInformation ticket)
已过时。
Use
Client.call(Writable, ConnectionId) instead |
static VersionedProtocol |
RPC.getProxy(Class<? extends VersionedProtocol> 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.
|
static VersionedProtocol |
RPC.getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
static VersionedProtocol |
RPC.getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
boolean checkVersion)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
| 限定符和类型 | 字段和说明 |
|---|---|
protected UserGroupInformation |
JobContext.ugi
The UserGroupInformation object that has a reference to the current user
|
| 限定符和类型 | 方法和说明 |
|---|---|
UserGroupInformation |
JobTokenIdentifier.getUser()
Get the Ugi with the username encoded in the token identifier
|
| 限定符和类型 | 方法和说明 |
|---|---|
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.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.loginUserFromKeytabAndReturnUGI(String user,
String path)
Log a user in from a keytab file.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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 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) |
| 限定符和类型 | 方法和说明 |
|---|---|
abstract UserGroupInformation |
TokenIdentifier.getUser()
Get the Ugi with the username encoded in the token identifier
|
| 限定符和类型 | 方法和说明 |
|---|---|
UserGroupInformation |
AbstractDelegationTokenIdentifier.getUser()
Get the username encoded in the token identifier
|
Copyright © 2009 The Apache Software Foundation