Package kieker.extension.cassandra.reader

Class CassandraSourceStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.extension.cassandra.reader.CassandraSourceStage

public class CassandraSourceStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>

Reader from Cassandra DB.

Since:

1.16

Author:

Armin Moebius, Sven Ulrich, Reiner Jung

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor	Description
CassandraSourceStage(String keyspace, String[] contactPoints, String tablePrefix)

Method Summary

Modifier and Type	Method	Description
protected void	execute()

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, 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 Details

CassandraSourceStage

public CassandraSourceStage(String keyspace,
 String[] contactPoints,
 String tablePrefix)

Method Details

execute

protected void execute()
                throws Exception

Specified by:

execute in class teetime.framework.AbstractStage

Throws:

Exception