public class TaskAttemptContext extends JobContext implements Progressable
CACHE_ARCHIVES_VISIBILITIES, CACHE_FILE_VISIBILITIES, COMBINE_CLASS_ATTR, conf, credentials, INPUT_FORMAT_CLASS_ATTR, JOB_ACL_MODIFY_JOB, JOB_ACL_VIEW_JOB, JOB_CANCEL_DELEGATION_TOKEN, JOB_NAMENODES, MAP_CLASS_ATTR, OUTPUT_FORMAT_CLASS_ATTR, PARTITIONER_CLASS_ATTR, REDUCE_CLASS_ATTR, ugi, USER_LOG_RETAIN_HOURS
构造器和说明 |
---|
TaskAttemptContext(Configuration conf,
TaskAttemptID taskId) |
限定符和类型 | 方法和说明 |
---|---|
String |
getStatus()
Get the last set status message.
|
TaskAttemptID |
getTaskAttemptID()
Get the unique name for this task attempt.
|
void |
progress()
Report progress.
|
void |
setStatus(String msg)
Set the current status of the task to the given string.
|
getCombinerClass, getConfiguration, getCredentials, getGroupingComparator, getInputFormatClass, getJar, getJobID, getJobName, getMapOutputKeyClass, getMapOutputValueClass, getMapperClass, getNumReduceTasks, getOutputFormatClass, getOutputKeyClass, getOutputValueClass, getPartitionerClass, getReducerClass, getSortComparator, getWorkingDirectory
public TaskAttemptContext(Configuration conf, TaskAttemptID taskId)
public TaskAttemptID getTaskAttemptID()
public void setStatus(String msg) throws IOException
IOException
public String getStatus()
public void progress()
progress
在接口中 Progressable
Copyright © 2009 The Apache Software Foundation