Modifier and Type | Method and Description |
---|---|
Token<?>[] |
FileSystem.addDelegationTokens(String renewer,
Credentials credentials)
Obtain all delegation tokens used by this FileSystem that are not
already present in the given Credentials.
|
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 Credentials |
DelegationTokenFetcher.getDTfromRemote(String nnAddr,
String renewer) |
Modifier and Type | Method and Description |
---|---|
Credentials |
JobConf.getCredentials()
Get credentials for the job.
|
Modifier and Type | Method and Description |
---|---|
ApplicationSubmissionContext |
YARNRunner.createApplicationSubmissionContext(Configuration jobConf,
String jobSubmitDir,
Credentials ts) |
void |
JobConf.setCredentials(Credentials credentials) |
JobStatus |
YARNRunner.submitJob(JobID jobId,
String jobSubmitDir,
Credentials ts) |
JobStatus |
LocalJobRunner.submitJob(JobID jobid,
String jobSubmitDir,
Credentials credentials) |
Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
ReduceTaskAttemptImpl(TaskId id,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
int numMapTasks,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
Credentials |
JobContext.getCredentials()
Get credentials for the job.
|
Modifier and Type | Method and Description |
---|---|
static void |
ClientDistributedCacheManager.getDelegationTokens(Configuration job,
Credentials credentials)
For each archive or cache file - get the corresponding delegation token
|
Modifier and Type | Method and Description |
---|---|
Credentials |
WrappedMapper.Context.getCredentials() |
Modifier and Type | Method and Description |
---|---|
Credentials |
WrappedReducer.Context.getCredentials() |
Modifier and Type | Method and Description |
---|---|
JobStatus |
ClientProtocol.submitJob(JobID jobId,
String jobSubmitDir,
Credentials ts)
Submit a Job for execution.
|
Modifier and Type | Method and Description |
---|---|
static Credentials |
TokenCache.loadTokens(String jobTokenFile,
Configuration conf)
Deprecated.
Use
readTokenStorageFile(org.apache.hadoop.fs.Path, org.apache.hadoop.conf.Configuration) instead,
this method is included for compatibility against Hadoop-1. |
static Credentials |
TokenCache.loadTokens(String jobTokenFile,
JobConf conf)
Deprecated.
Use
readTokenStorageFile(org.apache.hadoop.fs.Path, org.apache.hadoop.conf.Configuration) instead,
this method is included for compatibility against Hadoop-1. |
Modifier and Type | Method and Description |
---|---|
static Token<?> |
TokenCache.getDelegationToken(Credentials credentials,
String namenode)
Deprecated.
Use
getToken(org.apache.hadoop.io.Text)
instead, this method is included for compatibility against Hadoop-1 |
static Token<JobTokenIdentifier> |
TokenCache.getJobToken(Credentials credentials) |
static byte[] |
TokenCache.getSecretKey(Credentials credentials,
Text alias)
auxiliary method to get user's secret keys..
|
static byte[] |
TokenCache.getShuffleSecretKey(Credentials credentials) |
static void |
TokenCache.obtainTokensForNamenodes(Credentials credentials,
Path[] ps,
Configuration conf)
Convenience method to obtain delegation tokens from namenodes
corresponding to the paths passed.
|
static void |
TokenCache.setJobToken(Token<? extends TokenIdentifier> t,
Credentials credentials)
store job token
|
static void |
TokenCache.setShuffleSecretKey(byte[] key,
Credentials credentials) |
Modifier and Type | Field and Description |
---|---|
protected Credentials |
JobContextImpl.credentials |
Modifier and Type | Method and Description |
---|---|
Credentials |
JobContextImpl.getCredentials() |
Modifier and Type | Method and Description |
---|---|
protected Credentials |
MRAppMaster.getCredentials() |
Modifier and Type | Field and Description |
---|---|
protected Credentials |
TaskImpl.credentials |
Constructor and Description |
---|
JobImpl(JobId jobId,
ApplicationAttemptId applicationAttemptId,
Configuration conf,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
JobTokenSecretManager jobTokenSecretManager,
Credentials jobCredentials,
Clock clock,
Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
TaskAttemptImpl(TaskId taskId,
int i,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
Path jobFile,
int partition,
JobConf conf,
String[] dataLocalHosts,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
Credentials |
UserGroupInformation.getCredentials()
Obtain the tokens in credentials form associated with this user.
|
static Credentials |
Credentials.readTokenStorageFile(File filename,
Configuration conf)
Convenience method for reading a token storage file, and loading the Tokens
therein in the passed UGI
|
static Credentials |
Credentials.readTokenStorageFile(Path filename,
Configuration conf)
Convenience method for reading a token storage file, and loading the Tokens
therein in the passed UGI
|
Modifier and Type | Method and Description |
---|---|
void |
Credentials.addAll(Credentials other)
Copy all of the credentials from one credential object into another.
|
void |
UserGroupInformation.addCredentials(Credentials credentials)
Add the given Credentials to this user.
|
void |
Credentials.mergeAll(Credentials other)
Copy all of the credentials from one credential object into another.
|
Constructor and Description |
---|
Credentials(Credentials credentials)
Create a copy of the given credentials
|
Modifier and Type | Method and Description |
---|---|
protected Credentials |
CopyListing.getCredentials()
get credentials to update the delegation tokens for accessed FS objects
|
Modifier and Type | Method and Description |
---|---|
static CopyListing |
CopyListing.getCopyListing(Configuration configuration,
Credentials credentials,
DistCpOptions options)
Public Factory method with which the appropriate CopyListing implementation may be retrieved.
|
protected void |
CopyListing.setCredentials(Credentials credentials)
set Credentials store, on which FS delegatin token will be cached
|
Constructor and Description |
---|
CopyListing(Configuration configuration,
Credentials credentials)
Protected constructor, to initialize configuration.
|
FileBasedCopyListing(Configuration configuration,
Credentials credentials)
Constructor, to initialize base-class.
|
GlobbedCopyListing(Configuration configuration,
Credentials credentials)
Constructor, to initialize the configuration.
|
SimpleCopyListing(Configuration configuration,
Credentials credentials)
Protected constructor, to initialize configuration.
|
Constructor and Description |
---|
ApplicationImpl(Dispatcher dispatcher,
ApplicationACLsManager aclsManager,
String user,
ApplicationId appId,
Credentials credentials,
Context context) |
Modifier and Type | Method and Description |
---|---|
Credentials |
ContainerImpl.getCredentials() |
Credentials |
Container.getCredentials() |
Constructor and Description |
---|
ContainerImpl(Configuration conf,
Dispatcher dispatcher,
ContainerLaunchContext launchContext,
Credentials creds,
NodeManagerMetrics metrics,
ContainerTokenIdentifier containerTokenIdentifier) |
Modifier and Type | Method and Description |
---|---|
Credentials |
LocalizerContext.getCredentials() |
Constructor and Description |
---|
LocalizerContext(String user,
ContainerId containerId,
Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
protected void |
LogAggregationService.initAppAggregator(ApplicationId appId,
String user,
Credentials credentials,
ContainerLogsRetentionPolicy logRetentionPolicy,
Map<ApplicationAccessType,String> appAcls) |
Modifier and Type | Method and Description |
---|---|
Credentials |
LogHandlerAppStartedEvent.getCredentials() |
Constructor and Description |
---|
LogHandlerAppStartedEvent(ApplicationId appId,
String user,
Credentials credentials,
ContainerLogsRetentionPolicy retentionPolicy,
Map<ApplicationAccessType,String> appAcls) |
Modifier and Type | Method and Description |
---|---|
Credentials |
RMStateStore.ApplicationAttemptState.getAppAttemptCredentials() |
Constructor and Description |
---|
RMStateStore.ApplicationAttemptState(ApplicationAttemptId attemptId,
Container masterContainer,
Credentials appAttemptCredentials) |
Modifier and Type | Method and Description |
---|---|
void |
DelegationTokenRenewer.addApplication(ApplicationId applicationId,
Credentials ts,
boolean shouldCancelAtEnd)
Add application tokens for renewal.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.