org.apache.hadoop.examples

类 PiEstimator.PiMapper

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.apache.hadoop.examples.PiEstimator.PiMapper

所有已实现的接口:

Closeable, AutoCloseable, JobConfigurable, Mapper<LongWritable,LongWritable,BooleanWritable,LongWritable>

封闭类:

PiEstimator

public static class PiEstimator.PiMapper
extends MapReduceBase
implements Mapper<LongWritable,LongWritable,BooleanWritable,LongWritable>

Mapper class for Pi estimation. Generate points in a unit square and then count points inside/outside of the inscribed circle of the square.

构造器概要

构造器

构造器和说明
PiEstimator.PiMapper()

方法概要

方法

限定符和类型	方法和说明
void	map(LongWritable offset, LongWritable size, OutputCollector<BooleanWritable,LongWritable> out, Reporter reporter) Map method.

从类继承的方法 org.apache.hadoop.mapred.MapReduceBase

close, configure

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

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

从接口继承的方法 org.apache.hadoop.mapred.JobConfigurable

configure

从接口继承的方法 java.io.Closeable

close

构造器详细资料

PiEstimator.PiMapper

public PiEstimator.PiMapper()

方法详细资料

map

public void map(LongWritable offset,
       LongWritable size,
       OutputCollector<BooleanWritable,LongWritable> out,
       Reporter reporter)
         throws IOException

Map method.

指定者:

map 在接口中 Mapper<LongWritable,LongWritable,BooleanWritable,LongWritable>

参数:

offset - samples starting from the (offset+1)th sample.

size - the number of samples for this map

out - output {ture->numInside, false->numOutside}

reporter -

抛出:

IOException