Struct DuckDbQueryAdapter 

pub struct DuckDbQueryAdapter { /* private fields */ }

Generates DuckDB-compatible SQL queries over exported Parquet files.

This adapter does not embed DuckDB as a dependency; instead it produces SQL strings that can be sent to an external DuckDB process or connection pool.

Implementations

impl DuckDbQueryAdapter

pub fn new(path: impl Into<String>) -> Self

Create an adapter for a Parquet file or glob (e.g. /data/*.parquet).

pub fn parquet_path(&self) -> &str

Return the configured Parquet path / glob.

pub fn select_metric(&self, metric: &str, start_ms: i64, end_ms: i64) -> String

Generate SQL to select all rows for a specific metric within a time range.

pub fn aggregate_metric( &self, metric: &str, start_ms: i64, end_ms: i64, aggregation: AggregationFunction, ) -> String

Generate SQL to compute per-metric aggregates over a time range.

pub fn resample(&self, metric: &str, bucket_ms: i64) -> String

Generate SQL to downsample data into fixed-width time buckets (ms).

pub fn export_query_to_parquet(&self, query: &str, output_path: &str) -> String

Generate SQL to export query results back to another Parquet file.

pub fn list_metrics(&self) -> String

Generate SQL to list distinct metrics in the dataset.

pub fn time_range_summary(&self) -> String

Generate SQL to compute a time-range summary for all metrics.

pub fn join_metrics( &self, metric_a: &str, metric_b: &str, bucket_ms: i64, ) -> String

Generate SQL to join two metric time-series by timestamp bucket.

pub fn rate_of_change(&self, metric: &str, bucket_ms: i64) -> String

Generate SQL to compute rate of change (derivative) per bucket.

pub fn create_view(&self, view_name: &str) -> String

Generate SQL to create a DuckDB view for repeated queries.

pub fn count_per_metric(&self) -> String

Generate SQL to count total data points per metric.

Trait Implementations

impl Clone for DuckDbQueryAdapter

fn clone(&self) -> DuckDbQueryAdapter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DuckDbQueryAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.