org.apache.hadoop.examples
Class PiEstimator.PiReducer

java.lang.Object
  org.apache.hadoop.mapred.MapReduceBase
      org.apache.hadoop.examples.PiEstimator.PiReducer

All Implemented Interfaces:

Closeable, JobConfigurable, Reducer<LongWritable,LongWritable,WritableComparable,Writable>

Enclosing class:

PiEstimator

public static class PiEstimator.PiReducer
extends MapReduceBase
implements Reducer<LongWritable,LongWritable,WritableComparable,Writable>

Constructor Summary

PiEstimator.PiReducer()

Method Summary

void	close() Default implementation that does nothing.
void	configure(JobConf job) Reducer configuration.
void	reduce(LongWritable key, Iterator<LongWritable> values, OutputCollector<WritableComparable,Writable> output, Reporter reporter) Reduce method.

Methods inherited from class java.lang.Object

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

Constructor Detail

PiEstimator.PiReducer

public PiEstimator.PiReducer()

Method Detail

configure

public void configure(JobConf job)

Reducer configuration.

Specified by:

configure in interface JobConfigurable

Overrides:

configure in class MapReduceBase

Parameters:

job - the configuration

reduce

public void reduce(LongWritable key,
                   Iterator<LongWritable> values,
                   OutputCollector<WritableComparable,Writable> output,
                   Reporter reporter)
            throws IOException

Reduce method.

Specified by:

reduce in interface Reducer<LongWritable,LongWritable,WritableComparable,Writable>

Parameters:

key -

values -

output -

reporter -

Throws:

IOException

close

public void close()
           throws IOException

Description copied from class: MapReduceBase

Default implementation that does nothing.

Specified by:

close in interface Closeable

Overrides:

close in class MapReduceBase

Throws:

IOException