org.galagosearch.tupleflow
Class OrderedReader<T>

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

All Implemented Interfaces:

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

public abstract class OrderedReader<T>
extends java.lang.Object
implements TypeReader<T>, ExNihiloSource<T>

Field Summary

protected int	batchCount
protected ArrayInput	input
protected T	last
protected boolean	needsInit
protected Processor<T>	processor

Constructor Summary

OrderedReader(ArrayInput input)

OrderedReader(ArrayInput input, Processor<T> processor)

Method Summary

abstract T	clone(T object)
T	read()
void	readTuple()
void	run()
void	setProcessor(Processor<T> processor)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.galagosearch.tupleflow.Source

setProcessor

Field Detail

processor

protected Processor<T> processor

input

protected ArrayInput input

needsInit

protected boolean needsInit

last

protected T last

batchCount

protected int batchCount

Constructor Detail

OrderedReader

public OrderedReader(ArrayInput input,
                     Processor<T> processor)

OrderedReader

public OrderedReader(ArrayInput input)

Method Detail

setProcessor

public void setProcessor(Processor<T> processor)

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

read

public T read()
       throws java.io.IOException

Specified by:

read in interface TypeReader<T>

Throws:

java.io.IOException

readTuple

public void readTuple()
               throws java.io.IOException

Throws:

java.io.IOException

clone

public abstract T clone(T object)