kieker.analysisteetime.util.stage

Class FunctionStage<I,O>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

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

kieker.analysisteetime.util.stage.FunctionStage<I,O>

Type Parameters:

I - Type of input elements

O - Type of output elements

All Implemented Interfaces:

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

public class FunctionStage<I,O>
extends teetime.stage.basic.AbstractTransformation<I,O>

Stage that maps the elements from its input port to its output port by using a Function.

Since:

1.14

Author:

Sören Henning

Field Summary

Fields inherited from class teetime.stage.basic.AbstractTransformation

outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
FunctionStage(java.util.function.Function<I,O> function)

Method Summary

Modifier and Type	Method and Description
protected void	execute(I element)
java.util.function.Function<I,O>	getFunction()
void	setFunction(java.util.function.Function<I,O> function)

Methods inherited from class teetime.stage.basic.AbstractTransformation

getOutputPort

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, 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

Constructor Detail

FunctionStage

public FunctionStage(java.util.function.Function<I,O> function)

Method Detail

getFunction

public java.util.function.Function<I,O> getFunction()

setFunction

public void setFunction(java.util.function.Function<I,O> function)

execute

protected void execute(I element)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<I>