kieker.analysis.sink

Class DataSinkStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<IMonitoringRecord>

kieker.analysis.sink.DataSinkStage

public class DataSinkStage
extends teetime.framework.AbstractConsumerStage<IMonitoringRecord>

Sync all incoming records with a Kieker writer. You need to provide a kieker configuration object for the writer to be used.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
DataSinkStage(Configuration configuration) Configure and setup the Kieker writer.

Method Summary

Modifier and Type	Method and Description
protected void	execute(IMonitoringRecord record)
long	getCount()

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

Constructor Detail

DataSinkStage

public DataSinkStage(Configuration configuration)

Configure and setup the Kieker writer.

Parameters:

configuration - kieker configuration containing the dump stage writer setup

Method Detail

execute

protected void execute(IMonitoringRecord record)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<IMonitoringRecord>

getCount

public long getCount()