net.sf.eos.hadoop.mapred.index
Class IndexMapper<K extends WritableComparable>
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
net.sf.eos.hadoop.mapred.EosDocumentSupportMapReduceBase
net.sf.eos.hadoop.mapred.index.IndexMapper<K>
- All Implemented Interfaces:
- Closeable, JobConfigurable, Mapper<K,Text,K,Text>
public class IndexMapper<K extends WritableComparable>
- extends EosDocumentSupportMapReduceBase
- implements Mapper<K,Text,K,Text>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IndexMapper
public IndexMapper()
map
public void map(K key,
Text value,
OutputCollector<K,Text> output,
Reporter reporter)
throws IOException
- Specified by:
map
in interface Mapper<K extends WritableComparable,Text,K extends WritableComparable,Text>
- Throws:
IOException
configure
public void configure(JobConf conf)
- Specified by:
configure
in interface JobConfigurable
- Overrides:
configure
in class EosDocumentSupportMapReduceBase
- Parameters:
conf
- the configuration
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Overrides:
close
in class EosDocumentSupportMapReduceBase
- Throws:
IOException
Copyright © 2008. All Rights Reserved.