teetime.stage.basic

Class AbstractTransformation<I,O>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<I,O>

Type Parameters:

I - the type of the input port

O - the type of the output port

All Implemented Interfaces:

ITransformation<I,O>

Direct Known Subclasses:

AbstractFilter, ApplyXSLTToDocumentStage, ByteArray2String, ElementsToList, EveryXthStage, File2ByteArray, File2Lines, File2SeqOfWords, File2TextLinesFilter, LoadXMLToDocumentStage, MappingCounter

public abstract class AbstractTransformation<I,O>
extends AbstractConsumerStage<I>
implements ITransformation<I,O>

Since:

2.0

Author:

Christian Wulf

Field Summary

Fields

Modifier and Type	Field and Description
protected OutputPort<O>	outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTransformation()

Method Summary

Modifier and Type	Method and Description
OutputPort<O>	getOutputPort()

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, execute, execute, getInputPort

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Methods inherited from interface teetime.stage.basic.ITransformation

getInputPort

Field Detail

outputPort

protected final OutputPort<O> outputPort

Constructor Detail

AbstractTransformation

protected AbstractTransformation()

Method Detail

getOutputPort

public final OutputPort<O> getOutputPort()

Specified by:

getOutputPort in interface ITransformation<I,O>