teetime.framework

Class CompositeStage

java.lang.Object

teetime.framework.CompositeStage

Direct Known Subclasses:

Configuration, EveryXthPrinter, QuicksortStage, StaticTaskFarmStage, TaskFarmStage, WordCounter

public class CompositeStage
extends Object

Represents a minimal stage that composes several other stages. In order to work with this class, you need to extend from it and work from within the extending class.

Since:

2.0

Author:

Christian Wulf, Nelson Tavares de Sousa

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_PIPE_CAPACITY Default capacity for pipes

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompositeStage()

Method Summary

Modifier and Type	Method and Description
protected <T> void	connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Connects two ports with a pipe with a default capacity of currently 512.
protected <T> void	connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity) Connects to ports with a pipe of a certain capacity
protected <T> InputPort<T>	createInputPort(InputPort<T> subStageInputPort)
protected <T> OutputPort<T>	createOutputPort(OutputPort<T> subStageOutputPort)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PIPE_CAPACITY

protected static final int DEFAULT_PIPE_CAPACITY

Default capacity for pipes

See Also:

Constant Field Values

Constructor Detail

CompositeStage

protected CompositeStage()

Method Detail

connectPorts

protected final <T> void connectPorts(OutputPort<? extends T> sourcePort,
                                      InputPort<T> targetPort)

Connects two ports with a pipe with a default capacity of currently 512.

Type Parameters:

T - the type of elements to be sent

Parameters:

sourcePort - OutputPort of the sending stage

targetPort - InputPort of the sending stage

connectPorts

protected <T> void connectPorts(OutputPort<? extends T> sourcePort,
                                InputPort<T> targetPort,
                                int capacity)

Connects to ports with a pipe of a certain capacity

Type Parameters:

T - the type of elements to be sent

Parameters:

sourcePort - OutputPort of the sending stage

targetPort - InputPort of the sending stage

capacity - the pipe is set to this capacity, if the value is greater than 0. If it is 0, than the pipe is unbounded, thus growing of the pipe is enabled.

createInputPort

protected <T> InputPort<T> createInputPort(InputPort<T> subStageInputPort)

createOutputPort

protected <T> OutputPort<T> createOutputPort(OutputPort<T> subStageOutputPort)