org.galagosearch.tupleflow
Class OrderedCombiner<T>

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

All Implemented Interfaces:

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

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

Author:

trevor

Nested Class Summary

static class

OrderedCombiner.SortPair<T>

Field Summary

Step

processor

Constructor Summary

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

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

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

Method Summary

void	close()
static <S> OrderedCombiner	combineFromFiles(java.util.List<java.lang.String> filenames)
static <S> OrderedCombiner	combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order)
static <S> OrderedCombiner	combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order, Processor<S> processor)
static <S> OrderedCombiner	combineFromFiles(java.util.List<java.lang.String> filenames, Order<S> order, Processor<S> processor, boolean closeOnExit, int bufferSize)
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 Step processor

Constructor Detail

OrderedCombiner

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

OrderedCombiner

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

OrderedCombiner

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

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

combineFromFiles

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

Throws:

java.io.IOException

combineFromFiles

public static <S> OrderedCombiner combineFromFiles(java.util.List<java.lang.String> filenames,
                                                   Order<S> order,
                                                   Processor<S> processor,
                                                   boolean closeOnExit,
                                                   int bufferSize)
                                        throws java.io.IOException

Throws:

java.io.IOException

combineFromFiles

public static <S> OrderedCombiner combineFromFiles(java.util.List<java.lang.String> filenames)
                                        throws java.io.IOException

Throws:

java.io.IOException

combineFromFiles

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

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

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