org.galagosearch.core.parse
Class WordCounter

java.lang.Object
  org.galagosearch.tupleflow.StandardStep<Document,org.galagosearch.core.types.WordCount>
      org.galagosearch.core.parse.WordCounter

All Implemented Interfaces:

org.galagosearch.tupleflow.Processor<Document>, org.galagosearch.tupleflow.Reducer<org.galagosearch.core.types.WordCount>, org.galagosearch.tupleflow.Source<org.galagosearch.core.types.WordCount>, org.galagosearch.tupleflow.Step

@InputClass(className="org.galagosearch.core.parse.Document")
@OutputClass(className="org.galagosearch.core.types.WordCount")
public class WordCounter
extends org.galagosearch.tupleflow.StandardStep<Document,org.galagosearch.core.types.WordCount>
implements org.galagosearch.tupleflow.Reducer<org.galagosearch.core.types.WordCount>

Author:

trevor

Field Summary

Fields inherited from class org.galagosearch.tupleflow.StandardStep

processor

Constructor Summary

WordCounter(org.galagosearch.tupleflow.TupleFlowParameters parameters)

Method Summary

void	process(Document document)
java.util.ArrayList<org.galagosearch.core.types.WordCount>	reduce(java.util.List<org.galagosearch.core.types.WordCount> input)

Methods inherited from class org.galagosearch.tupleflow.StandardStep

close, setProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

WordCounter

public WordCounter(org.galagosearch.tupleflow.TupleFlowParameters parameters)
            throws java.io.IOException

Throws:

java.io.IOException

Method Detail

process

public void process(Document document)
             throws java.io.IOException

Specified by:

process in interface org.galagosearch.tupleflow.Processor<Document>

Specified by:

process in class org.galagosearch.tupleflow.StandardStep<Document,org.galagosearch.core.types.WordCount>

Throws:

java.io.IOException

reduce

public java.util.ArrayList<org.galagosearch.core.types.WordCount> reduce(java.util.List<org.galagosearch.core.types.WordCount> input)
                                                                  throws java.io.IOException

Specified by:

reduce in interface org.galagosearch.tupleflow.Reducer<org.galagosearch.core.types.WordCount>

Throws:

java.io.IOException