org.galagosearch.core.parse
Class WordCountReducer

java.lang.Object
  org.galagosearch.core.parse.WordCountReducer

All Implemented Interfaces:

org.galagosearch.core.types.WordCount.Processor, org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount>, 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.types.WordCount",
            order="+word")
@OutputClass(className="org.galagosearch.core.types.WordCount",
             order="+word")
public class WordCountReducer
extends java.lang.Object
implements org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount>, org.galagosearch.tupleflow.Source<org.galagosearch.core.types.WordCount>, org.galagosearch.tupleflow.Reducer<org.galagosearch.core.types.WordCount>, org.galagosearch.core.types.WordCount.Processor

Author:

trevor

Field Summary

org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount>

processor

Constructor Summary

WordCountReducer()

Method Summary

void	close()
void	flush()
java.lang.Class<org.galagosearch.core.types.WordCount>	getInputClass()
java.lang.Class<org.galagosearch.core.types.WordCount>	getOutputClass()
long	getTotalTerms()
void	process(org.galagosearch.core.types.WordCount wordCount)
java.util.ArrayList<org.galagosearch.core.types.WordCount>	reduce(java.util.List<org.galagosearch.core.types.WordCount> input)
void	setProcessor(org.galagosearch.tupleflow.Step processor)

Methods inherited from class java.lang.Object

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

Field Detail

processor

public org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount> processor

Constructor Detail

WordCountReducer

public WordCountReducer()

Method Detail

process

public void process(org.galagosearch.core.types.WordCount wordCount)
             throws java.io.IOException

Specified by:

process in interface org.galagosearch.core.types.WordCount.Processor

Specified by:

process in interface org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount>

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.galagosearch.core.types.WordCount.Processor

Specified by:

close in interface org.galagosearch.tupleflow.Processor<org.galagosearch.core.types.WordCount>

Throws:

java.io.IOException

setProcessor

public void setProcessor(org.galagosearch.tupleflow.Step processor)
                  throws org.galagosearch.tupleflow.IncompatibleProcessorException

Specified by:

setProcessor in interface org.galagosearch.tupleflow.Source<org.galagosearch.core.types.WordCount>

Throws:

org.galagosearch.tupleflow.IncompatibleProcessorException

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

getTotalTerms

public long getTotalTerms()

getInputClass

public java.lang.Class<org.galagosearch.core.types.WordCount> getInputClass()

getOutputClass

public java.lang.Class<org.galagosearch.core.types.WordCount> getOutputClass()