Struct CteRegistry 

pub struct CteRegistry { /* private fields */ }

Registry for CTE results during query execution

Uses Arc with COW (copy-on-write) semantics to avoid cloning:

• During building: Arc::make_mut gives mutable access without cloning (single owner)
• During sharing: data() returns cheap Arc clone (O(1), no data copy)

Implementations

impl CteRegistry

pub fn new() -> Self

Create a new CTE registry

pub fn store(&mut self, name: &str, columns: Vec<String>, rows: RowVec)

Store a materialized CTE result

Uses Arc::make_mut for COW semantics:

• If we’re the only owner, mutates in place (no clone)
• If shared, clones first then mutates (preserves other references)

Both columns and rows are wrapped in Arc to enable zero-copy sharing. Accepts RowVec and converts to CompactArc<Vec<(i64, Row)>> for sharing.

pub fn store_arc( &mut self, name: &str, columns: CompactArc<Vec<String>>, rows: CompactArc<Vec<(i64, Row)>>, materialized_rows: Arc<OnceLock<CompactArc<Vec<Row>>>>, )

Store a materialized CTE result with pre-wrapped Arcs

Use this when you already have Arc-wrapped data to avoid cloning. This enables zero-copy sharing of CTE results between queries.

pub fn get(&self, name: &str) -> Option<&CteData>

Look up a materialized CTE by case-insensitive name.

pub fn data(&self) -> Arc<CteDataMap>

Get a shared Arc reference to the internal data map for context transfer

This is always O(1) - just an Arc reference count increment. No data cloning ever happens here.

pub fn iter(&self) -> impl Iterator<Item = (&String, &CteData)>

Iterate over all stored CTEs (for copying to temp registries)

Trait Implementations

impl Clone for CteRegistry

fn clone(&self) -> CteRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CteRegistry

fn default() -> Self

Returns the “default value” for a type.