org.apache.hadoop.mapreduce

类 Mapper.Context

java.lang.Object

org.apache.hadoop.mapreduce.JobContext

org.apache.hadoop.mapreduce.TaskAttemptContext

org.apache.hadoop.mapreduce.TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

org.apache.hadoop.mapreduce.MapContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

org.apache.hadoop.mapreduce.Mapper.Context

所有已实现的接口:

Progressable

封闭类:

Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

public class Mapper.Context
extends MapContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

字段概要

从类继承的字段 org.apache.hadoop.mapreduce.JobContext

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

构造器概要

构造器

构造器和说明
Mapper.Context(Configuration conf, TaskAttemptID taskid, RecordReader<KEYIN,VALUEIN> reader, RecordWriter<KEYOUT,VALUEOUT> writer, OutputCommitter committer, StatusReporter reporter, InputSplit split)

方法概要

从类继承的方法 org.apache.hadoop.mapreduce.MapContext

getCurrentKey, getCurrentValue, getInputSplit, nextKeyValue

从类继承的方法 org.apache.hadoop.mapreduce.TaskInputOutputContext

getCounter, getCounter, getOutputCommitter, getProgress, progress, setStatus, write

从类继承的方法 org.apache.hadoop.mapreduce.TaskAttemptContext

getStatus, getTaskAttemptID

从类继承的方法 org.apache.hadoop.mapreduce.JobContext

getCombinerClass, getConfiguration, getCredentials, getGroupingComparator, getInputFormatClass, getJar, getJobID, getJobName, getMapOutputKeyClass, getMapOutputValueClass, getMapperClass, getNumReduceTasks, getOutputFormatClass, getOutputKeyClass, getOutputValueClass, getPartitionerClass, getReducerClass, getSortComparator, getWorkingDirectory

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

Mapper.Context

public Mapper.Context(Configuration conf,
              TaskAttemptID taskid,
              RecordReader<KEYIN,VALUEIN> reader,
              RecordWriter<KEYOUT,VALUEOUT> writer,
              OutputCommitter committer,
              StatusReporter reporter,
              InputSplit split)
               throws IOException,
                      InterruptedException

抛出:

IOException

InterruptedException