org.galagosearch.tupleflow
Class SequentialCombiner<T>

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

All Implemented Interfaces:

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

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

Author:

trevor

Field Summary

Processor<T>

processor

Constructor Summary

SequentialCombiner(java.util.List<java.lang.String> filenames, Order<T> order)
Creates a new instance of SequentialCombiner

Method Summary

static <S> SequentialCombiner<S>	combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order)
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

Field Detail

processor

public Processor<T> processor

Constructor Detail

SequentialCombiner

public SequentialCombiner(java.util.List<java.lang.String> filenames,
                          Order<T> order)

Creates a new instance of SequentialCombiner

Method Detail

getOutputClass

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

setProcessor

public void setProcessor(Step processor)
                  throws IncompatibleProcessorException

Specified by:

setProcessor in interface Source<T>

Throws:

IncompatibleProcessorException

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

combineFromFiles

public static <S> SequentialCombiner<S> combineFromFiles(java.util.List<java.lang.String> filenames,
                                                         Order<S> order)
                                              throws java.io.IOException

Throws:

java.io.IOException

read

public T read()
       throws java.io.IOException

Specified by:

read in interface TypeReader<T>

Throws:

java.io.IOException