org.apache.hadoop.examples

类 SleepJob.SleepInputFormat

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.examples.SleepJob.SleepInputFormat

所有已实现的接口:

Configurable, InputFormat<IntWritable,IntWritable>

封闭类:

SleepJob

public static class SleepJob.SleepInputFormat
extends Configured
implements InputFormat<IntWritable,IntWritable>

构造器概要

构造器

构造器和说明
SleepJob.SleepInputFormat()

方法概要

方法

限定符和类型	方法和说明
RecordReader<IntWritable,IntWritable>	getRecordReader(InputSplit ignored, JobConf conf, Reporter reporter) Get the RecordReader for the given InputSplit.
InputSplit[]	getSplits(JobConf conf, int numSplits) Logically split the set of input files for the job.

从类继承的方法 org.apache.hadoop.conf.Configured

getConf, setConf

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

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

构造器详细资料

SleepJob.SleepInputFormat

public SleepJob.SleepInputFormat()

方法详细资料

getSplits

public InputSplit[] getSplits(JobConf conf,
                     int numSplits)

从接口复制的说明: InputFormat

Logically split the set of input files for the job.

Each InputSplit is then assigned to an individual Mapper for processing.

Note: The split is a logical split of the inputs and the input files are not physically split into chunks. For e.g. a split could be <input-file-path, start, offset> tuple.

指定者:

getSplits 在接口中 InputFormat<IntWritable,IntWritable>

参数:

conf - job configuration.

numSplits - the desired number of splits, a hint.

返回:

an array of InputSplits for the job.

getRecordReader

public RecordReader<IntWritable,IntWritable> getRecordReader(InputSplit ignored,
                                                    JobConf conf,
                                                    Reporter reporter)
                                                      throws IOException

从接口复制的说明: InputFormat

Get the RecordReader for the given InputSplit.

It is the responsibility of the RecordReader to respect record boundaries while processing the logical split to present a record-oriented view to the individual task.

指定者:

getRecordReader 在接口中 InputFormat<IntWritable,IntWritable>

参数:

ignored - the InputSplit

conf - the job that this split belongs to

返回:

a RecordReader

抛出:

IOException