timelake 0.5.0

//! The Timelake reader: DataFusion over Timelake tables.
//!
//! What it adds over a generic Iceberg/Parquet scan (SPEC §12.2):
//! - **File pruning** on Iceberg column bounds (time range, series key) evaluated with DataFusion's
//!   `PruningPredicate`, then row-group and page pruning inside the (sorted) Parquet files.
//! - **Last-value rewrite:** "newest row per series" queries (`ROW_NUMBER() OVER (PARTITION BY
//!   <series key> ORDER BY <time> DESC) = 1`) and "newest row" queries (`ORDER BY <time> DESC
//!   LIMIT 1` filtered on the series key) are answered from the last-value index instead of a scan.
//! - **Dedup on read:** in tables with dedup on, files that may share a `(series…, time)` are
//!   merged and only the newest write of each key is returned, before compaction removes the rest.
//! - **Rollup routing:** `GROUP BY time_bucket(…)` queries read the buckets a rollup has right from
//!   the rollup, and the rest from the raw table (SPEC §11.1).
//! - `time_bucket(interval, ts [, origin])`, an alias of `date_bin`.
//! - Namespaces as SQL schemas: `SELECT … FROM iot.readings`.

mod catalog;
mod dedup;
mod provider;
mod rewrite;
mod rollup;
mod route;
mod session;
mod settings;
mod statement;
mod stats;

pub(crate) use rollup::{refresh_session, rollup_frame};
pub use session::Session;
pub use settings::SessionSettings;
pub use statement::{RollupStatement, Statement};

/// Name of the lake's catalog in SQL.
const CATALOG: &str = "timelake";

/// How long a table version loaded for planning is reused by later planning in this process.
/// Commits made by this process are visible immediately regardless.
const PLAN_CACHE_TTL: std::time::Duration = std::time::Duration::from_secs(1);