icydb-core 0.179.3

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

//! Module: executor::aggregate::contracts
//! Responsibility: aggregate runtime contracts, specs, grouped state, and errors.
//! Does not own: aggregate execution branching/orchestration behavior.
//! Boundary: shared aggregate contract surface consumed by aggregate executors.
#![deny(unreachable_patterns)]

mod error;
mod grouped;
mod plan;
mod spec;
mod state;

pub(in crate::db::executor) use error::GroupError;
pub(in crate::db::executor) use grouped::{
    ExecutionConfig, ExecutionContext, ScalarAggregateEngine, execute_scalar_aggregate,
};
#[cfg(test)]
pub(in crate::db::executor) use plan::BinaryOp;
pub(in crate::db::executor) use plan::{
    AccessPlannedQuery, AggregateKind, CompiledExpr, CoveringProjectionFacts,
    CoveringProjectionOrder, EffectiveRuntimeFilterProgram, Expr, FieldId, FieldSlot,
    GlobalDistinctAggregateKind, GroupedAggregateExecutionSpec, GroupedDistinctExecutionStrategy,
    GroupedExecutionConfig, OrderDirection, OrderSpec, PageSpec, PlannedProjectionLayout,
    ProjectionField, ProjectionSpec, admit_true_only_boolean_value,
    compile_scalar_projection_expr_from_schema, constant_covering_projection_value_from_access,
    eval_builder_expr_for_value_preview, global_distinct_group_spec_for_aggregate_identity,
    plan_covering_index_adjacent_distinct_eligible, plan_covering_index_projection_facts,
};
pub(in crate::db::executor) use spec::{ScalarAggregateOutput, ScalarTerminalKind};
pub(in crate::db::executor) use state::{
    AggregateFoldMode, AggregateStateFactory, FoldControl, GroupedDistinctExecutionMode,
    GroupedTerminalAggregateState,
};