org.galagosearch.core.parse
Class UniversalParser

java.lang.Object
  org.galagosearch.tupleflow.StandardStep<org.galagosearch.core.types.DocumentSplit,Document>
      org.galagosearch.core.parse.UniversalParser

All Implemented Interfaces:

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

@InputClass(className="org.galagosearch.core.types.DocumentSplit")
@OutputClass(className="org.galagosearch.core.parse.Document")
public class UniversalParser
extends org.galagosearch.tupleflow.StandardStep<org.galagosearch.core.types.DocumentSplit,Document>

Author:

trevor

Field Summary

Fields inherited from class org.galagosearch.tupleflow.StandardStep

processor

Constructor Summary

UniversalParser(org.galagosearch.tupleflow.TupleFlowParameters parameters)

Method Summary

java.io.BufferedInputStream	getBufferedInputStream(org.galagosearch.core.types.DocumentSplit split)
java.io.BufferedReader	getBufferedReader(org.galagosearch.core.types.DocumentSplit split)
void	process(org.galagosearch.core.types.DocumentSplit split)

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

UniversalParser

public UniversalParser(org.galagosearch.tupleflow.TupleFlowParameters parameters)

Method Detail

getBufferedReader

public java.io.BufferedReader getBufferedReader(org.galagosearch.core.types.DocumentSplit split)
                                         throws java.io.IOException

Throws:

java.io.IOException

getBufferedInputStream

public java.io.BufferedInputStream getBufferedInputStream(org.galagosearch.core.types.DocumentSplit split)
                                                   throws java.io.IOException

Throws:

java.io.IOException

process

public void process(org.galagosearch.core.types.DocumentSplit split)
             throws java.io.IOException

Specified by:

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

Specified by:

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

Throws:

java.io.IOException