org.apache.hadoop.examples.dancing

类 DistributedPentomino.PentMap

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.apache.hadoop.examples.dancing.DistributedPentomino.PentMap

所有已实现的接口:

Closeable, AutoCloseable, JobConfigurable, Mapper<WritableComparable,Text,Text,Text>

封闭类:

DistributedPentomino

public static class DistributedPentomino.PentMap
extends MapReduceBase
implements Mapper<WritableComparable,Text,Text,Text>

Each map takes a line, which represents a prefix move and finds all of the solutions that start with that prefix. The output is the prefix as the key and the solution as the value.

构造器概要

构造器

构造器和说明
DistributedPentomino.PentMap()

方法概要

方法

限定符和类型	方法和说明
void	configure(JobConf conf) Default implementation that does nothing.
void	map(WritableComparable key, Text value, OutputCollector<Text,Text> output, Reporter reporter) Break the prefix string into moves (a sequence of integer row ids that will be selected for each column in order).

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

close

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

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

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

close

构造器详细资料

DistributedPentomino.PentMap

public DistributedPentomino.PentMap()

方法详细资料

map

public void map(WritableComparable key,
       Text value,
       OutputCollector<Text,Text> output,
       Reporter reporter)
         throws IOException

Break the prefix string into moves (a sequence of integer row ids that will be selected for each column in order). Find all solutions with that prefix.

指定者:

map 在接口中 Mapper<WritableComparable,Text,Text,Text>

参数:

key - the input key.

value - the input value.

output - collects mapped keys and values.

reporter - facility to report progress.

抛出:

IOException

configure

public void configure(JobConf conf)

从类复制的说明: MapReduceBase

Default implementation that does nothing.

指定者:

configure 在接口中 JobConfigurable

覆盖:

configure 在类中 MapReduceBase

参数:

conf - the configuration