Uses of Interface
org.galagosearch.tupleflow.Processor

Packages that use Processor

org.galagosearch.tupleflow
org.galagosearch.tupleflow.execution

Uses of Processor in org.galagosearch.tupleflow

Classes in org.galagosearch.tupleflow that implement Processor

class	FileOrderedWriter<T>
class	Multi<T>
class	NullProcessor<T>
class	OrderedWriter<T>
class	Sorter<T> This class sorts an incoming stream of objects in some specified order.
class	Splitter<T>
class	StandardStep<T,U> This is the base class for most TupleFlow steps.
class	Unique<T>
class	XMLMinimum

Fields in org.galagosearch.tupleflow declared as Processor

Processor<T>	StreamCombiner.processor
Processor<U>	StandardStep.processor
Processor<T>	SequentialCombiner.processor
Processor<T>	Select.processor
protected Processor<T>	OrderedReader.processor
Processor<T>	NullSource.processor
Processor<org.galagosearch.tupleflow.types.FileName>	FileSource.processor

Methods in org.galagosearch.tupleflow that return Processor

Processor	TupleFlowParameters.getTypeWriter(java.lang.String specification)
Processor	FakeParameters.getTypeWriter(java.lang.String specification)
Processor<T>	Order.orderedWriter(ArrayOutput output) Produces an OrderedWriter object that can write objects of class T in this order.

Methods in org.galagosearch.tupleflow with parameters of type Processor

static <S> OrderedCombiner	OrderedCombiner.combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order, Processor<S> processor)
static <S> OrderedCombiner	OrderedCombiner.combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order, Processor<S> processor, boolean closeOnExit, int bufferSize)
void	OrderedReader.setProcessor(Processor<T> processor)

Constructors in org.galagosearch.tupleflow with parameters of type Processor

Multi(Processor[] processors)
Creates a new instance of Multi

OrderedCombiner(TypeReader<T>[] inputs, FileOrderedReader<T>[] files, Order<T> order, Processor<T> processor, boolean closeOnExit)

OrderedCombiner(TypeReader<T>[] inputs, Order<T> order, Processor<T> processor)

OrderedReader(ArrayInput input, Processor<T> processor)

Sorter(int limit, Order<T> order, Reducer<T> reducer, Processor<T> processor)

Splitter(Processor<T>[] processors, Order<T> order)

Unique(java.util.Comparator<T> sameObject, Processor<T> processor)
Creates a new instance of Unique

Constructor parameters in org.galagosearch.tupleflow with type arguments of type Processor

Multi(java.util.List<Processor> processors)

Uses of Processor in org.galagosearch.tupleflow.execution

Methods in org.galagosearch.tupleflow.execution that return Processor

static Processor	StageInstanceFactory.getTypeWriter(StageInstanceDescription.PipeInput pipeInput)
Processor	StageInstanceFactory.StepParameters.getTypeWriter(java.lang.String specification)