org.apache.hadoop.examples.pi

Class DistSum.Machine.AbstractInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<NullWritable,SummationWritable>

org.apache.hadoop.examples.pi.DistSum.Machine.AbstractInputFormat

Direct Known Subclasses:

DistSum.MapSide.PartitionInputFormat, DistSum.ReduceSide.SummationInputFormat

Enclosing class:

DistSum.Machine

public abstract static class DistSum.Machine.AbstractInputFormat
extends InputFormat<NullWritable,SummationWritable>

An abstract InputFormat for the jobs

Constructor Summary

Constructors

Constructor and Description
DistSum.Machine.AbstractInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
RecordReader<NullWritable,SummationWritable>	createRecordReader(InputSplit generic, TaskAttemptContext context) Specify how to read the records

Methods inherited from class org.apache.hadoop.mapreduce.InputFormat

getSplits

Methods inherited from class java.lang.Object

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

Constructor Detail

DistSum.Machine.AbstractInputFormat

public DistSum.Machine.AbstractInputFormat()

Method Detail

createRecordReader

public final RecordReader<NullWritable,SummationWritable> createRecordReader(InputSplit generic,
                                                              TaskAttemptContext context)

Specify how to read the records

Specified by:

createRecordReader in class InputFormat<NullWritable,SummationWritable>

Parameters:

generic - the split to be read

context - the information about the task

Returns:

a new record reader