uqa-execution 0.1.6

Volcano physical operators with row-batch pipelines
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Relational Volcano operators.
//!
//! Each operator family owns its state and lifecycle in a focused module while
//! this facade preserves the public construction API.

use std::sync::Arc;

use uqa_core::Value;
use uqa_sql::ast::SetOpKind;
use uqa_sql::expr::truthy;
#[cfg(test)]
use uqa_sql::ResultRow;
use uqa_sql::SQLParam;

use crate::batch::{Batch, RowSchema};
use crate::physical::{ExecError, ExecResult, PhysicalOperator};
use crate::scalar::{eval_scalar, ScalarEvalContext, ScalarExpr};

mod aggregate;
mod evaluator;
mod filter;
mod limit;
mod project;
mod set_operation;
mod sort;
mod window;

pub use aggregate::{AggregateExecutor, AggregateKind, AggregateSpec, HashAggregate};
pub use evaluator::{
    ExpressionEvaluator, RowPredicate, SharedExpressionEvaluator, SharedRowPredicate,
};
pub use filter::Filter;
pub use limit::Limit;
pub use project::Project;
pub use set_operation::SetOperation;
pub(crate) use sort::compare_sort_key_values_by;
pub use sort::{compare_sort_key_values, Sort, SortKey};
pub use window::{Window, WindowExecutor, WindowKind, WindowSpec};

use aggregate::value_to_f64;
use evaluator::DefaultExpressionEvaluator;
use sort::compare_values;

#[cfg(test)]
use aggregate::{finalise_fold, AggFold};

#[cfg(test)]
mod tests;