kieker.analysis.sink

Class NullStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<java.lang.Object>

kieker.analysis.sink.NullStage

public class NullStage
extends teetime.framework.AbstractConsumerStage<java.lang.Object>

Act like a null device.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_REPORT_INTERVAL

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
NullStage(boolean silent) Null stage.
NullStage(boolean silent, int reportInterval) Null stage.

Method Summary

Modifier and Type	Method and Description
protected void	execute(java.lang.Object record)
long	getCount()
java.util.Map<java.lang.Class<? extends java.lang.Object>,java.lang.Integer>	getTypes()
protected void	onTerminating()

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

Field Detail

DEFAULT_REPORT_INTERVAL

public static final int DEFAULT_REPORT_INTERVAL

See Also:

Constant Field Values

Constructor Detail

NullStage

public NullStage(boolean silent)

Null stage.

Parameters:

silent - silent operations.

NullStage

public NullStage(boolean silent,
                 int reportInterval)

Null stage.

Parameters:

silent - silent operations.

reportInterval - number of records to be received before logging

Method Detail

onTerminating

protected void onTerminating()

Overrides:

onTerminating in class teetime.framework.AbstractStage

execute

protected void execute(java.lang.Object record)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<java.lang.Object>

getCount

public long getCount()

getTypes

public java.util.Map<java.lang.Class<? extends java.lang.Object>,java.lang.Integer> getTypes()