Class AggregatedSlidingWindowTimeReservoir

  • All Implemented Interfaces:
    TimeReservoir<AggregatedValueObject>

    class AggregatedSlidingWindowTimeReservoir
    extends AbstractSlidingWindowTimeReservoir<AggregatedValueObject>
    Aggregated sliding window time reservoir stores aggregated measurements in a time window of given size. The resulting snapshot provides precise data as far as the granularity of aggregating trimmer is not concerned. The granularity of the trimmer determines the granularity of the data the snapshot provides. In other words, the aggregated value object is either included in the resulting measurements or not depending whether it was trimmed or not.
    • Constructor Detail

      • AggregatedSlidingWindowTimeReservoir

        public AggregatedSlidingWindowTimeReservoir​(long window,
                                                    java.util.concurrent.TimeUnit windowUnit,
                                                    long startTime,
                                                    java.util.concurrent.TimeUnit startTimeUnit,
                                                    AggregatingTrimmer notifier)
        Creates an aggregated sliding window reservoir.
        Parameters:
        window - The time size of the window
        windowUnit - The unit of the window size
        startTime - The start time from when to calculate the statistics
        startTimeUnit - The unit of the start time
        notifier - The aggregating trimmer that produces the aggregated data