org.apache.hadoop.examples

类 PiEstimator.PiReducer

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.apache.hadoop.examples.PiEstimator.PiReducer

所有已实现的接口:

Closeable, AutoCloseable, JobConfigurable, Reducer<BooleanWritable,LongWritable,WritableComparable<?>,Writable>

封闭类:

PiEstimator

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

Reducer class for Pi estimation. Accumulate points inside/outside results from the mappers.

构造器概要

构造器

构造器和说明
PiEstimator.PiReducer()

方法概要

方法

限定符和类型	方法和说明
void	close() Reduce task done, write output to a file.
void	configure(JobConf job) Store job configuration.
void	reduce(BooleanWritable isInside, Iterator<LongWritable> values, OutputCollector<WritableComparable<?>,Writable> output, Reporter reporter) Accumulate number of points inside/outside results from the mappers.

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

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

构造器详细资料

PiEstimator.PiReducer

public PiEstimator.PiReducer()

方法详细资料

configure

public void configure(JobConf job)

Store job configuration.

指定者:

configure 在接口中 JobConfigurable

覆盖:

configure 在类中 MapReduceBase

参数:

job - the configuration

reduce

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

Accumulate number of points inside/outside results from the mappers.

指定者:

reduce 在接口中 Reducer<BooleanWritable,LongWritable,WritableComparable<?>,Writable>

参数:

isInside - Is the points inside?

values - An iterator to a list of point counts

output - dummy, not used here.

reporter -

抛出:

IOException

close

public void close()
           throws IOException

Reduce task done, write output to a file.

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 MapReduceBase

抛出:

IOException