org.galagosearch.tupleflow
Class FileOrderedReader<T>

java.lang.Object
  org.galagosearch.tupleflow.FileOrderedReader<T>

All Implemented Interfaces:

ExNihiloSource<T>, ReaderSource<T>, Source<T>, Step, TypeReader<T>

public class FileOrderedReader<T>
extends java.lang.Object
implements ReaderSource<T>

Author:

trevor

Constructor Summary

FileOrderedReader(java.lang.String filename)

FileOrderedReader(java.lang.String filename, int bufferSize, boolean compressed)

FileOrderedReader(java.lang.String filename, Order<T> order)

FileOrderedReader(java.lang.String filename, Order<T> order, int bufferSize)

FileOrderedReader(java.lang.String filename, Order<T> order, int bufferSize, boolean compressed)
Creates a new instance of FileOrderedReader

Method Summary

void	close()
Order<T>	getOrder()
TypeReader<T>	getOrderedReader()
java.lang.Class<T>	getOutputClass()
T	read()
void	run()
void	setProcessor(Step processor)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileOrderedReader

public FileOrderedReader(java.lang.String filename,
                         int bufferSize,
                         boolean compressed)
                  throws java.io.IOException

Throws:

java.io.IOException

FileOrderedReader

public FileOrderedReader(java.lang.String filename)
                  throws java.io.IOException

Throws:

java.io.IOException

FileOrderedReader

public FileOrderedReader(java.lang.String filename,
                         Order<T> order,
                         int bufferSize,
                         boolean compressed)
                  throws java.io.IOException

Creates a new instance of FileOrderedReader

Throws:

java.io.IOException

FileOrderedReader

public FileOrderedReader(java.lang.String filename,
                         Order<T> order,
                         int bufferSize)
                  throws java.io.IOException

Throws:

java.io.IOException

FileOrderedReader

public FileOrderedReader(java.lang.String filename,
                         Order<T> order)
                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setProcessor

public void setProcessor(Step processor)
                  throws IncompatibleProcessorException

Specified by:

setProcessor in interface Source<T>

Throws:

IncompatibleProcessorException

getOutputClass

public java.lang.Class<T> getOutputClass()

run

public void run()
         throws java.io.IOException

Specified by:

run in interface ExNihiloSource<T>

Specified by:

run in interface TypeReader<T>

Throws:

java.io.IOException

getOrder

public Order<T> getOrder()

getOrderedReader

public TypeReader<T> getOrderedReader()

read

public T read()
       throws java.io.IOException

Specified by:

read in interface TypeReader<T>

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException