Crate chronix_query 

chronix-query

Query engine for the Chronix time-series database.

This crate implements the full query pipeline:

1. Planning — QueryPlan and QueryBuilder for fluent query construction
2. Pruning — Multi-level segment elimination (time, bloom, stats)
3. Projection — Read only the columns needed by the query
4. Filtering — Vectorized predicate evaluation on Arrow arrays
5. Deduplication — Sort-merge dedup for overlapping segments
6. Aggregation — count, sum, min, max, avg, first, last
7. Downsampling — Time-bucket aggregation
8. Window functions — row_number, rank, lead, lag, delta, rate, irate, moving average, cumulative sum, increase

All results are returned as Apache Arrow RecordBatch for zero-copy interoperability with data processing ecosystems.

Re-exports

pub use aggregate::AggFn;

pub use aggregate::AggResult;

pub use aggregate::DecimalTrack;

pub use aggregate::Num;

pub use convert::points_to_record_batch;

pub use encoded_pushdown::ColumnPredicate;

pub use encoded_pushdown::EncodedDomainEvaluator;

pub use encoded_pushdown::RowGroupVerdict;

pub use error::QueryError;

pub use memory::MemoryTracker;

pub use plan::QueryBuilder;

pub use plan::QueryPlan;

pub use window::WindowFn;

Modules

aggregate

Aggregation functions for query results.

convert

Conversion from Point collections to Arrow RecordBatch.

dedup

K-way merge deduplication for overlapping segments.

downsample

Time-bucket downsampling engine.

encoded_pushdown

Encoded-domain predicate pushdown — evaluates predicates against column statistics without decoding the actual data.

error

Query engine error types.

filter

Vectorized predicate filtering on Arrow arrays.

memory

Per-query memory tracking and budget enforcement.

plan

Query planning and fluent builder API.

pruning

Multi-level segment pruning pipeline.

window

Window functions for time-series query processing.

Structs

FieldPredicate

A field predicate that can be evaluated against per-row-group ColumnStats min/max to skip row groups that cannot possibly match.

Enums

StatsOp

A numeric comparison operator for zone-map row-group pruning.

Functions

arrow_cell_to_field_value

The inverse of column_type_to_arrow, for one cell.

column_type_to_arrow

The Arrow type a schema column decodes to — one answer, in one place.

extract_f64

Consolidated Arrow column → f64 extraction.