org.galagosearch.tupleflow
Class StreamCombiner<T>

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

All Implemented Interfaces:

ExNihiloSource<T>, Source<T>, Step

public class StreamCombiner<T>
extends java.lang.Object
implements ExNihiloSource<T>

Combines many streams of data together, sequentially. This is a replacement for a typical input step.

Author:

trevor

Field Summary

Processor<T>

processor

Constructor Summary

StreamCombiner(TupleFlowParameters parameters)

Method Summary

static java.lang.String	getInputClass(TupleFlowParameters parameters)
static java.lang.String[]	getInputOrder(TupleFlowParameters parameters)
static java.lang.String	getOutputClass(TupleFlowParameters parameters)
static java.lang.String[]	getOutputOrder(TupleFlowParameters parameters)
void	run()
void	setProcessor(Step processor)
static void	verify(TupleFlowParameters parameters, ErrorHandler handler)

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

StreamCombiner

public StreamCombiner(TupleFlowParameters parameters)
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

run

public void run()
         throws java.io.IOException

Specified by:

run in interface ExNihiloSource<T>

Throws:

java.io.IOException

setProcessor

public void setProcessor(Step processor)
                  throws IncompatibleProcessorException

Specified by:

setProcessor in interface Source<T>

Throws:

IncompatibleProcessorException

getInputClass

public static java.lang.String getInputClass(TupleFlowParameters parameters)

getOutputClass

public static java.lang.String getOutputClass(TupleFlowParameters parameters)

getOutputOrder

public static java.lang.String[] getOutputOrder(TupleFlowParameters parameters)

getInputOrder

public static java.lang.String[] getInputOrder(TupleFlowParameters parameters)

verify

public static void verify(TupleFlowParameters parameters,
                          ErrorHandler handler)
                   throws java.lang.ClassNotFoundException

Throws:

java.lang.ClassNotFoundException