public class OperationExecutionRecordTimestampFilter extends AbstractTimestampFilter<OperationExecutionRecord>
AbstractTimestampFilter
. Allows to filter OperationExecutionRecord
objects based on their given timestamps.
This stage receives trace events to be selected by a specific timestamp selector (based on tin and tout).recordOutsideTimePeriodOutputPort, recordWithinTimePeriodOutputPort
Constructor and Description |
---|
OperationExecutionRecordTimestampFilter(long ignoreBeforeTimestamp,
long ignoreAfterTimestamp) |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(OperationExecutionRecord execution) |
protected long |
getRecordSpecificTimestamp(OperationExecutionRecord execution)
Returns the most accurate timestamp available for each record.
|
getRecordOutsideTimePeriodOutputPort, getRecordWithinTimePeriodOutputPort, inRange
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, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public OperationExecutionRecordTimestampFilter(long ignoreBeforeTimestamp, long ignoreAfterTimestamp)
protected void execute(OperationExecutionRecord execution)
execute
in class AbstractTimestampFilter<OperationExecutionRecord>
protected long getRecordSpecificTimestamp(OperationExecutionRecord execution)
AbstractTimestampFilter
getRecordSpecificTimestamp
in class AbstractTimestampFilter<OperationExecutionRecord>
execution
- An EventRecord, OperationExecutionRecord, TraceMetadata or MonitoringRecord for example.Copyright 2020 Kieker Project, http://kieker-monitoring.net