org.apache.hadoop.mapred.gridmix

Class SleepJob.SleepInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<LongWritable,LongWritable>

org.apache.hadoop.mapred.gridmix.SleepJob.SleepInputFormat

Enclosing class:

SleepJob

public static class SleepJob.SleepInputFormat
extends InputFormat<LongWritable,LongWritable>

Constructor Summary

Constructors

Constructor and Description
SleepJob.SleepInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
RecordReader<LongWritable,LongWritable>	createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for a given split.
List<InputSplit>	getSplits(JobContext jobCtxt) Logically split the set of input files for the job.

Methods inherited from class java.lang.Object

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

Constructor Detail

SleepJob.SleepInputFormat

public SleepJob.SleepInputFormat()

Method Detail

getSplits

public List<InputSplit> getSplits(JobContext jobCtxt)
                           throws IOException

Description copied from class: 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. The InputFormat also creates the RecordReader to read the InputSplit.

Specified by:

getSplits in class InputFormat<LongWritable,LongWritable>

Parameters:

jobCtxt - job configuration.

Returns:

an array of InputSplits for the job.

Throws:

IOException

createRecordReader

public RecordReader<LongWritable,LongWritable> createRecordReader(InputSplit split,
                                                         TaskAttemptContext context)
                                                           throws IOException,
                                                                  InterruptedException

Description copied from class: InputFormat

Create a record reader for a given split. The framework will call RecordReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

Specified by:

createRecordReader in class InputFormat<LongWritable,LongWritable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException

InterruptedException