nodedb 0.4.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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

// SPDX-License-Identifier: BUSL-1.1

//! Join execution handlers — hash, sort-merge, broadcast, nested-loop, and lateral.

mod budget_guard;
mod grace_drive;
pub(super) mod grace_partitioner;
mod grace_probe;
mod grace_repartition;
mod grace_spill;
pub mod hash;
mod hash_handlers;
pub mod lateral;
pub mod nested_loop;
pub mod params;
mod row_source;
mod shuffle_join;
pub mod sort_merge;
mod spill;
mod support;

pub(crate) use params::{HashJoinParams, JoinParams, NestedLoopJoinParams, SortMergeJoinParams};
// Node-local shuffle-join completion inputs — reconstructed in the Data-Plane
// `QueryOp::ShuffleJoinConsume` dispatch arm (E4b).
pub(in crate::data::executor) use shuffle_join::ShuffleJoinInputs;

// Streaming frame reader over `[u32 LE len][row-bytes]` staged shuffle files.
// Shared with the distributed-aggregate consumer
// (`QueryOp::ShuffleAggregateConsume`), which reads the same frame format.
pub(in crate::data::executor) use grace_repartition::FrameStreamReader;

// `merge_join_docs_binary` is exercised directly by an integration test, so it
// stays crate-public. The rest are join-internal helpers (private re-export,
// visible to the join submodules via `super::`).
pub use support::merge_join_docs_binary;
use support::{binary_row_matches_filters, binary_row_project, compare_preextracted};