org.galagosearch.tupleflow.execution
Class StageInstanceFactory

java.lang.Object
  org.galagosearch.tupleflow.execution.StageInstanceFactory

public class StageInstanceFactory
extends java.lang.Object

Author:

trevor

Nested Class Summary

class

StageInstanceFactory.StepParameters

Constructor Summary

StageInstanceFactory(NetworkedCounterManager counterManager)

Method Summary

protected static Order	createOrder(DataPipe pipe)
static Order	createOrder(java.lang.String className, java.lang.String[] orderSpec)
static <T> ReaderSource<T>	getTypeReader(StageInstanceDescription.PipeOutput pipeOutput)
ReaderSource	getTypeReaderSource(StageInstanceDescription.PipeOutput pipeOutput)
static Processor	getTypeWriter(StageInstanceDescription.PipeInput pipeInput)
ExNihiloSource	instantiate(StageInstanceDescription instance)
Step	instantiate(StageInstanceDescription instance, java.util.ArrayList<Step> steps)
Step	instantiateInput(StageInstanceDescription instance, InputStep step)
Step	instantiateOutput(StageInstanceDescription instance, OutputStep step)
Step	instantiateStep(StageInstanceDescription instance, Step step)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StageInstanceFactory

public StageInstanceFactory(NetworkedCounterManager counterManager)

Method Detail

instantiate

public ExNihiloSource instantiate(StageInstanceDescription instance)
                           throws IncompatibleProcessorException,
                                  java.io.IOException

Throws:

IncompatibleProcessorException

java.io.IOException

instantiate

public Step instantiate(StageInstanceDescription instance,
                        java.util.ArrayList<Step> steps)
                 throws IncompatibleProcessorException,
                        java.io.IOException

Throws:

IncompatibleProcessorException

java.io.IOException

instantiateStep

public Step instantiateStep(StageInstanceDescription instance,
                            Step step)
                     throws java.io.IOException

Throws:

java.io.IOException

instantiateInput

public Step instantiateInput(StageInstanceDescription instance,
                             InputStep step)
                      throws java.io.IOException

Throws:

java.io.IOException

instantiateOutput

public Step instantiateOutput(StageInstanceDescription instance,
                              OutputStep step)
                       throws java.io.IOException

Throws:

java.io.IOException

createOrder

protected static Order createOrder(DataPipe pipe)
                            throws java.io.IOException

Throws:

java.io.IOException

createOrder

public static Order createOrder(java.lang.String className,
                                java.lang.String[] orderSpec)
                         throws java.io.IOException

Throws:

java.io.IOException

getTypeReaderSource

public ReaderSource getTypeReaderSource(StageInstanceDescription.PipeOutput pipeOutput)
                                 throws java.io.IOException

Throws:

java.io.IOException

getTypeReader

public static <T> ReaderSource<T> getTypeReader(StageInstanceDescription.PipeOutput pipeOutput)
                                     throws java.io.IOException

Throws:

java.io.IOException

getTypeWriter

public static Processor getTypeWriter(StageInstanceDescription.PipeInput pipeInput)
                               throws java.io.IOException,
                                      java.io.IOException

Throws:

java.io.IOException