icydb-core 0.213.34

IcyDB — A schema-first typed query engine and persistence runtime for Internet Computer canisters
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

//! Module: executor::aggregate
//! Responsibility: structural aggregate contracts and runtime execution.
//! Does not own: typed/dynamic result adapters or logical query planning.
//! Boundary: consumes accepted prepared plans and emits structural aggregate rows.

pub(in crate::db::executor) mod capability;
mod contracts;
#[cfg(feature = "sql")]
mod count_terminal;
pub(in crate::db::executor) mod field;
pub(in crate::db::executor) mod runtime;
#[cfg(feature = "sql")]
mod scalar_terminals;
#[cfg(feature = "diagnostics")]
mod terminal_attribution;
pub(in crate::db::executor::aggregate) mod value_reducer;

pub(in crate::db::executor) use capability::{
    AggregateExecutionPolicyInputs, derive_aggregate_execution_policy,
    field_target_is_tie_free_probe_target,
};
#[cfg(all(test, feature = "sql"))]
pub(in crate::db::executor) use contracts::BinaryOp;
#[cfg(feature = "sql")]
pub(in crate::db::executor) use contracts::FieldId;
#[cfg(feature = "diagnostics")]
pub(in crate::db::executor) use contracts::GroupedRuntimeStats;
pub(in crate::db::executor) use contracts::{
    AccessPlannedQuery, AggregateFoldMode, AggregateKind, CompiledExpr,
    EffectiveRuntimeFilterProgram, ExecutionConfig, ExecutionContext, FieldSlot, FoldControl,
    GlobalDistinctAggregateKind, GroupError, GroupedAggregateExecutionSpec,
    GroupedDistinctExecutionStrategy, OrderDirection, PlannedProjectionLayout, ProjectionSpec,
};
#[cfg(feature = "sql")]
pub(in crate::db::executor) use contracts::{
    Expr, PageSpec, ProjectionField, admit_true_only_boolean_value,
    compile_scalar_projection_expr_from_schema,
};
#[cfg(feature = "sql")]
pub(in crate::db) use count_terminal::execute_direct_count_index_prefix_cardinality_for_canister;
#[cfg(feature = "sql")]
pub(in crate::db) use scalar_terminals::{
    StructuralAggregateRequest, StructuralAggregateTerminal, StructuralAggregateTerminalKind,
    execute_structural_aggregate_rows_for_canister,
};
#[cfg(feature = "diagnostics")]
pub(in crate::db) use terminal_attribution::{
    ScalarAggregateTerminalAttribution, with_scalar_aggregate_terminal_attribution,
};