net.sf.eos.hadoop.mapred.decompose
Class SentencerMapper

java.lang.Object
  org.apache.hadoop.mapred.MapReduceBase
      net.sf.eos.hadoop.mapred.EosDocumentSupportMapReduceBase
          net.sf.eos.hadoop.mapred.decompose.SentencerMapper

All Implemented Interfaces:

Closeable, JobConfigurable, Mapper<LongWritable,Text,Text,Text>

public class SentencerMapper
extends EosDocumentSupportMapReduceBase
implements Mapper<LongWritable,Text,Text,Text>

Constructor Summary

SentencerMapper()

Method Summary

void	close()
void	configure(JobConf conf)
void	map(LongWritable positionInFile, Text eosDoc, OutputCollector<Text,Text> outputCollector, Reporter reporter)
protected KeyGenerator<Text>	newGenerator()

Methods inherited from class net.sf.eos.hadoop.mapred.EosDocumentSupportMapReduceBase

eosDocumentToText, getSerializer, textToEosDocument

Methods inherited from class java.lang.Object

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

Constructor Detail

SentencerMapper

public SentencerMapper()

Method Detail

map

public void map(LongWritable positionInFile,
                Text eosDoc,
                OutputCollector<Text,Text> outputCollector,
                Reporter reporter)
         throws IOException

Specified by:

map in interface Mapper<LongWritable,Text,Text,Text>

Throws:

IOException

newGenerator

protected KeyGenerator<Text> newGenerator()
                                   throws EosException

Throws:

EosException

configure

public void configure(JobConf conf)

Specified by:

configure in interface JobConfigurable

Overrides:

configure in class EosDocumentSupportMapReduceBase

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Overrides:

close in class EosDocumentSupportMapReduceBase

Throws:

IOException