Package kieker.analysis.generic.time

Class TimestampFilter

java.lang.Object
teetime.framework.CompositeStage
kieker.analysis.generic.time.TimestampFilter
public class TimestampFilter extends teetime.framework.CompositeStage
Allows to filter IMonitoringRecord objects based on their given timestamps. It handles flow events with their own timestamp and logging timestamp for all other records and event types. This class has several specialized internal filters to distinguish different timestamps for different record types. It has one input port and two output ports. If the received record is within the defined timestamps, the object is delivered unmodified to the recordsWithinTimePeriodOutputPort, otherwise to the recordsOutsideTimePeriodOutputPort.
Since:
1.2
Author:
Andre van Hoorn, Jan Waller, Lars Bluemke

  • Field Details

    • CONFIG_PROPERTY_VALUE_MAX_TIMESTAMP

      public static final String CONFIG_PROPERTY_VALUE_MAX_TIMESTAMP
      See Also:

    • CONFIG_PROPERTY_VALUE_MIN_TIMESTAMP

      public static final String CONFIG_PROPERTY_VALUE_MIN_TIMESTAMP
      The default used lower limit for the records.
      See Also:

  • Constructor Details

    • TimestampFilter

      public TimestampFilter(long ignoreBeforeTimestamp, long ignoreAfterTimestamp)
      Creates a new instance of this class using the given parameters.
      Parameters:
      ignoreBeforeTimestamp - The lower limit for the time stamps of the records.
      ignoreAfterTimestamp - The upper limit for the time stamps of the records.

  • Method Details

    • getMonitoringRecordsCombinedInputPort

      public teetime.framework.InputPort<IMonitoringRecord> getMonitoringRecordsCombinedInputPort()
      Returns the input port for the records.
      Returns:
      The input port.

    • getRecordsWithinTimePeriodOutputPort

      public teetime.framework.OutputPort<IMonitoringRecord> getRecordsWithinTimePeriodOutputPort()
      Returns the output port for the records whose timestamps are within the defined time period.
      Returns:
      The recordsWithinTimePeriod output port.

    • getRecordsOutsideTimePeriodOutputPort

      public teetime.framework.OutputPort<IMonitoringRecord> getRecordsOutsideTimePeriodOutputPort()
      Returns the output port for the records whose timestamps are outside the defined time period.
      Returns:
      The recordsOutsideTimePeriod output port.