org.galagosearch.tupleflow
Class Select<T>

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

All Implemented Interfaces:

ExNihiloSource<T>, Source<T>, Step

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

Takes two inputs, keys and values. Each item in the values list that matches a key is sent to the next stage. Items are assumed to be sorted in order by "order". That order also determines equality.

Author:

trevor

Field Summary

Processor<T>

processor

Constructor Summary

Select(TupleFlowParameters parameters)

Method Summary

java.lang.Class<T>	getOutputClass(TupleFlowParameters parameters)
void	run()
void	setProcessor(Step next)
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

Select

public Select(TupleFlowParameters parameters)
       throws java.io.IOException,
              java.lang.ClassNotFoundException,
              java.lang.NoSuchMethodException,
              java.lang.IllegalArgumentException,
              java.lang.reflect.InvocationTargetException,
              java.lang.InstantiationException,
              java.lang.IllegalAccessException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

java.lang.NoSuchMethodException

java.lang.IllegalArgumentException

java.lang.reflect.InvocationTargetException

java.lang.InstantiationException

java.lang.IllegalAccessException

Method Detail

run

public void run()
         throws java.io.IOException

Specified by:

run in interface ExNihiloSource<T>

Throws:

java.io.IOException

getOutputClass

public java.lang.Class<T> getOutputClass(TupleFlowParameters parameters)
                                  throws java.lang.ClassNotFoundException

Throws:

java.lang.ClassNotFoundException

setProcessor

public void setProcessor(Step next)
                  throws IncompatibleProcessorException

Specified by:

setProcessor in interface Source<T>

Throws:

IncompatibleProcessorException

verify

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

Throws:

java.lang.ClassNotFoundException