icydb-core 0.68.2

IcyDB — A type-safe, embedded ORM and schema system for the Internet Computer
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! Module: db::executor::route::mode
//! Responsibility: route-owned direction/window/continuation-mode derivation helpers.
//! Does not own: access-shape capability decisions or route execution-mode selection.
//! Boundary: pure derivation primitives consumed by route planning.

use crate::db::{
    direction::Direction,
    query::{
        builder::AggregateExpr,
        plan::{AccessPlannedQuery, ExecutionOrderContract},
    },
};

use crate::db::executor::route::{RouteCapabilities, aggregate_extrema_direction};

// Route-owned aggregate non-count streaming gate.
// Field-target extrema uses route capability flags directly; non-target
// terminals use the shared streaming-safe/pushdown/index-range route gates.
pub(in crate::db::executor) fn aggregate_non_count_streaming_allowed(
    aggregate_expr: Option<&AggregateExpr>,
    capabilities: RouteCapabilities,
    secondary_pushdown_eligible: bool,
    index_range_limit_enabled: bool,
) -> bool {
    if let Some(aggregate) = aggregate_expr
        && aggregate.target_field().is_some()
    {
        return match aggregate_extrema_direction(aggregate.kind()) {
            Some(Direction::Asc) => capabilities.field_min_fast_path_eligible,
            Some(Direction::Desc) => capabilities.field_max_fast_path_eligible,
            None => false,
        };
    }

    if capabilities.stream_order_contract_safe || index_range_limit_enabled {
        return true;
    }

    // Secondary-order pushdown alone is not enough for canonical aggregate
    // streaming on non-field terminals. Those shapes share the ordered index
    // access contract with load execution, but stale secondary rows are
    // reconciled correctly only through the canonical materialized row path.
    // Keeping this lane materialized preserves aggregate/load parity for
    // `EXISTS`, `FIRST`, `LAST`, `MIN`, and `MAX` on ordered secondary shapes.
    let _ = secondary_pushdown_eligible;

    false
}

// Route-owned load streaming gate.
// Load execution remains streaming when canonical streaming-safe shapes
// apply or when route enabled index-range limit pushdown.
pub(in crate::db::executor) const fn load_streaming_allowed(
    capabilities: RouteCapabilities,
    index_range_limit_enabled: bool,
) -> bool {
    capabilities.stream_order_contract_safe || index_range_limit_enabled
}

pub(in crate::db::executor::route) fn derive_load_route_direction(
    plan: &AccessPlannedQuery,
) -> Direction {
    ExecutionOrderContract::from_plan(
        plan.grouped_plan().is_some(),
        plan.scalar_plan().order.as_ref(),
    )
    .primary_scan_direction()
}

pub(in crate::db::executor::route) fn derive_aggregate_route_direction(
    plan: &AccessPlannedQuery,
    aggregate: &AggregateExpr,
) -> Direction {
    if aggregate.target_field().is_some() {
        return aggregate_extrema_direction(aggregate.kind())
            .unwrap_or_else(|| derive_load_route_direction(plan));
    }

    derive_load_route_direction(plan)
}