Package kieker.analysis.generic
Class HandleMetadataRecordStage
java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<I>
teetime.stage.basic.AbstractTransformation<E,E>
teetime.stage.basic.AbstractFilter<IMonitoringRecord>
kieker.analysis.generic.HandleMetadataRecordStage
- All Implemented Interfaces:
teetime.stage.basic.ITransformation<IMonitoringRecord,IMonitoringRecord>
public class HandleMetadataRecordStage extends teetime.stage.basic.AbstractFilter<IMonitoringRecord>
Receive all events and filter out the metadata records and store its information in a metadata model.
Relay all other events.
- Since:
- 1.15
- Author:
- Reiner Jung
-
Field Summary
-
Constructor Summary
Constructors Constructor Description HandleMetadataRecordStage(java.util.Map<java.lang.String,KiekerMetadataRecord> metadataMap)
-
Method Summary
Modifier and Type Method Description protected void
execute(IMonitoringRecord element)
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
-
Constructor Details
-
HandleMetadataRecordStage
public HandleMetadataRecordStage(java.util.Map<java.lang.String,KiekerMetadataRecord> metadataMap)
-
-
Method Details
-
execute
- Specified by:
execute
in classteetime.framework.AbstractConsumerStage<IMonitoringRecord>
- Throws:
java.lang.Exception
-