| 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.