public class IndexUpdateMapper<K extends WritableComparable,V extends 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 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.
|
public static Class<? extends WritableComparable> getMapOutputKeyClass()
public static Class<? extends Writable> getMapOutputValueClass()
public void map(K key, V value, OutputCollector<Shard,IntermediateForm> output, Reporter reporter) throws IOException
map
in interface 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
public void configure(JobConf job)
MapReduceBase
configure
in interface JobConfigurable
configure
in class MapReduceBase
job
- the configurationpublic void close() throws IOException
MapReduceBase
close
in interface Closeable
close
in interface AutoCloseable
close
in class MapReduceBase
IOException
Copyright © 2010 The Apache Software Foundation