org.apache.hadoop.contrib.index.mapred

类 IndexUpdateMapper<K extends WritableComparable,V extends Writable>

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.apache.hadoop.contrib.index.mapred.IndexUpdateMapper<K,V>

所有已实现的接口:

Closeable, AutoCloseable, JobConfigurable, Mapper<K,V,Shard,IntermediateForm>

public class IndexUpdateMapper<K extends WritableComparable,V extends Writable>
extends MapReduceBase
implements Mapper<K,V,Shard,IntermediateForm>

This class applies local analysis on a key-value pair and then convert the result docid-operation pair to a shard-and-intermediate form pair.

构造器概要

构造器

构造器和说明
IndexUpdateMapper()

方法概要

方法

限定符和类型	方法和说明
void	close() Default implementation that does nothing.
void	configure(JobConf job) Default implementation that does nothing.
static Class<? extends WritableComparable>	getMapOutputKeyClass() Get the map output key class.
static Class<? extends Writable>	getMapOutputValueClass() Get the map output value class.
void	map(K key, V value, OutputCollector<Shard,IntermediateForm> output, Reporter reporter) Map a key-value pair to a shard-and-intermediate form pair.

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

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

构造器详细资料

IndexUpdateMapper

public IndexUpdateMapper()

方法详细资料

getMapOutputKeyClass

public static Class<? extends WritableComparable> getMapOutputKeyClass()

Get the map output key class.

返回:

the map output key class

getMapOutputValueClass

public static Class<? extends Writable> getMapOutputValueClass()

Get the map output value class.

返回:

the map output value class

map

public void map(K key,
       V value,
       OutputCollector<Shard,IntermediateForm> output,
       Reporter reporter)
         throws IOException

Map a key-value pair to a shard-and-intermediate form pair. Internally, the local analysis is first applied to map the key-value pair to a document id-and-operation pair, then the docid-and-operation pair is mapped to a shard-intermediate form pair. The intermediate form is of the form of a single-document ram index and/or a single delete term.

指定者:

map 在接口中 Mapper<K extends WritableComparable,V extends Writable,Shard,IntermediateForm>

参数:

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 job)

从类复制的说明: MapReduceBase

Default implementation that does nothing.

指定者:

configure 在接口中 JobConfigurable

覆盖:

configure 在类中 MapReduceBase

参数:

job - the configuration

close

public void close()
           throws IOException

从类复制的说明: MapReduceBase

Default implementation that does nothing.

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 MapReduceBase

抛出:

IOException