Module aggr_over_time 

Structs

AbsentOverTime

absent_over_time returns an empty vector if the range vector passed to it has any elements (floats or native histograms) and a 1-element vector with the value 1 if the range vector passed to it has no elements.

AvgOverTime

The average value of all points in the specified interval.

CountOverTime

The count of all values in the specified interval.

LastOverTime

The most recent point value in specified interval.

MaxOverTime

The maximum value of all points in the specified interval.

MinOverTime

The minimum value of all points in the specified interval.

PresentOverTime

the value 1 for any series in the specified interval.

SlidingExtrema 🔒

Reuses extrema candidates across windows whose bounds do not retreat.

StddevOverTime

the population standard deviation of the values in the specified interval. Prometheus’s implementation: https://github.com/prometheus/prometheus/blob/f55ab2217984770aa1eecd0f2d5f54580029b1c0/promql/functions.go#L556-L569

StdvarOverTime

the population standard variance of the values in the specified interval. DataFusion’s implementation: https://github.com/apache/arrow-datafusion/blob/292eb954fc0bad3a1febc597233ba26cb60bda3e/datafusion/physical-expr/src/aggregate/variance.rs#L224-#L241

SumOverTime

The sum of all values in the specified interval.

Enums

PresenceEvaluator 🔒

Constants

MAX_SLIDING_STEP_FRACTION 🔒

Reuse is taken only when a step advances at most this fraction of the window.

MIN_SLIDING_WINDOWS 🔒

Batches with fewer windows than this have too little repeated work to reclaim.

MIN_SLIDING_WINDOW_LENGTH 🔒

Below this average window length the per-sample bookkeeping is comparable to the scan it would replace.

Functions

absent_over_time_evaluator 🔒

avg_over_time 🔒

count_over_time_evaluator 🔒

evaluate_presence 🔒

is_better 🔒

last_over_time_evaluator 🔒

min_max_input_type 🔒

min_max_over_time_batch 🔒

present_over_time_evaluator 🔒

reuses_candidates 🔒

Whether reusing candidates across windows is expected to beat rescanning each one.

scan_extremum 🔒

Folds one window on its own, the way the per-window scan used to.

stddev_over_time 🔒

stdvar_over_time 🔒

sum_over_time 🔒