Package kieker.analysis.generic

Class TeeFilter

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<E,E>

teetime.stage.basic.AbstractFilter<Object>

kieker.analysis.generic.TeeFilter

All Implemented Interfaces:

teetime.stage.basic.ITransformation<Object,Object>

public class TeeFilter
extends teetime.stage.basic.AbstractFilter<Object>

This filter has exactly one input port and one output port. A simple message is printed to a configurable stream and all objects are forwarded to the output port.

Since:

1.2

Author:

Matthias Rohr, Jan Waller, Lars Bluemke

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TeeFilter.TeeFilterStreamType	Predefined types of streams for the TeeFilter. STDLOG = standard log STDOUT = standard output STDERR = standard error output NULL = filter doesn't print anything

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_ENCODING	The default value of the encoding property which determines that the filter uses utf-8.
static final boolean	DEFAULT_STREAM_APPEND	The default value of the stream property which determines that the filter appends or overwrites a file.

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	Description
TeeFilter(String fileName, String encoding, boolean append)	Creates a new instance of this class using the given parameters.
TeeFilter(TeeFilter.TeeFilterStreamType streamType, String encoding)	Creates a new instance of this class using the given parameters.

Method Summary

Modifier and Type	Method	Description
protected void	execute(Object object)	This method receives incoming objects from the filter's input port.
String	getPrintStreamName()
protected void	onTerminating()

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

DEFAULT_ENCODING

public static final String DEFAULT_ENCODING

The default value of the encoding property which determines that the filter uses utf-8.

See Also:

• Constant Field Values

DEFAULT_STREAM_APPEND

public static final boolean DEFAULT_STREAM_APPEND

The default value of the stream property which determines that the filter appends or overwrites a file.

See Also:

• Constant Field Values

Constructor Details

TeeFilter

public TeeFilter(TeeFilter.TeeFilterStreamType streamType,
 String encoding)

Creates a new instance of this class using the given parameters. Uses one of the predefined TeeFilter.TeeFilterStreamTypes.

Parameters:

streamType - Determines which of the predefined TeeFilter.TeeFilterStreamTypes the filter uses.

encoding - Determines which encoding the filter uses. Pass null for default encoding "UTF-8".

TeeFilter

public TeeFilter(String fileName,
 String encoding,
 boolean append)

Creates a new instance of this class using the given parameters. Uses a FileOutputStream.

Parameters:

fileName - The system dependent file name for the FileOutputStream.

encoding - Determines which encoding the filter uses. Pass null for default encoding "UTF-8".

append - Determines whether the filter appends or overwrites a file.

Method Details

onTerminating

protected void onTerminating()

Overrides:

onTerminating in class teetime.framework.AbstractStage

execute

protected void execute(Object object)

This method receives incoming objects from the filter's input port. Every object will be printed into a stream (based on the configuration) before the filter sends it to the output port.

Specified by:

execute in class teetime.framework.AbstractConsumerStage<Object>

Parameters:

object - The new object.

getPrintStreamName

public String getPrintStreamName()