public class IndexUpdateMapper<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends MapReduceBase implements Mapper<K,V,Shard,IntermediateForm>
Constructor and Description |
---|
IndexUpdateMapper() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Default implementation that does nothing.
|
void |
configure(JobConf job)
Default implementation that does nothing.
|
static java.lang.Class<? extends org.apache.hadoop.io.WritableComparable> |
getMapOutputKeyClass()
Get the map output key class.
|
static java.lang.Class<? extends org.apache.hadoop.io.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.
|
public static java.lang.Class<? extends org.apache.hadoop.io.WritableComparable> getMapOutputKeyClass()
public static java.lang.Class<? extends org.apache.hadoop.io.Writable> getMapOutputValueClass()
public void map(K key, V value, OutputCollector<Shard,IntermediateForm> output, Reporter reporter) throws java.io.IOException
map
in interface Mapper<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,Shard,IntermediateForm>
key
- the input key.value
- the input value.output
- collects mapped keys and values.reporter
- facility to report progress.java.io.IOException
public void configure(JobConf job)
MapReduceBase
configure
in interface JobConfigurable
configure
in class MapReduceBase
job
- the configurationpublic void close() throws java.io.IOException
MapReduceBase
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class MapReduceBase
java.io.IOException
Copyright © 2009 The Apache Software Foundation