public class NullStage
extends teetime.framework.AbstractConsumerStage<java.lang.Object>
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_REPORT_INTERVAL |
Constructor and Description |
---|
NullStage(boolean silent)
Null stage.
|
NullStage(boolean silent,
int reportInterval)
Null stage.
|
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() |
createInputPort, execute, getInputPort
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
public static final int DEFAULT_REPORT_INTERVAL
public NullStage(boolean silent)
silent
- silent operations.public NullStage(boolean silent, int reportInterval)
silent
- silent operations.reportInterval
- number of records to be received before loggingprotected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
protected void execute(java.lang.Object record)
execute
in class teetime.framework.AbstractConsumerStage<java.lang.Object>
public long getCount()
public java.util.Map<java.lang.Class<? extends java.lang.Object>,java.lang.Integer> getTypes()
Copyright 2021 Kieker Project, http://kieker-monitoring.net