Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce.security | |
org.apache.hadoop.mapreduce.security.token | |
org.apache.hadoop.mapreduce.v2.app.job.impl |
Modifier and Type | Method and Description |
---|---|
static ByteBuffer |
ShuffleHandler.serializeServiceData(Token<JobTokenIdentifier> jobToken)
A helper function to serialize the JobTokenIdentifier to be sent to the
ShuffleHandler as ServiceData.
|
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 |
---|---|
static Token<JobTokenIdentifier> |
TokenCache.getJobToken(Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
JobTokenIdentifier |
JobTokenSecretManager.createIdentifier()
Create an empty job token identifier
|
Modifier and Type | Method and Description |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
byte[] |
JobTokenSecretManager.createPassword(JobTokenIdentifier identifier)
Create a new password/secret for the given job token identifier.
|
byte[] |
JobTokenSecretManager.retrievePassword(JobTokenIdentifier identifier)
Look up the token password/secret for the given job token identifier.
|
Modifier and Type | Method and Description |
---|---|
void |
JobTokenSecretManager.addTokenForJob(String jobId,
Token<JobTokenIdentifier> token)
Add the job token of a job to cache
|
Modifier and Type | Field and Description |
---|---|
protected Token<JobTokenIdentifier> |
TaskImpl.jobToken |
Constructor and Description |
---|
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) |
Copyright © 2013 Apache Software Foundation. All rights reserved.