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 voidexecute(IMonitoringRecord element)Methods inherited from class teetime.framework.AbstractConsumerStage
createInputPort, execute, getInputPortMethods 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:
executein classteetime.framework.AbstractConsumerStage<IMonitoringRecord>- Throws:
java.lang.Exception
-