grafeo-core 0.5.30

Core graph models, indexes, and execution primitives for Grafeo
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

//! Disk spilling for queries that exceed available memory.
//!
//! When a sort or aggregation grows too large for RAM, we spill partitions to
//! disk and merge them back later. This lets queries complete even with limited
//! memory - just slower.
//!
//! | Component | Purpose |
//! | --------- | ------- |
//! | [`SpillManager`] | Manages spill file lifecycle with automatic cleanup |
//! | [`SpillFile`] | Read/write individual spill files |
//! | [`ExternalSort`] | External merge sort for big ORDER BY |
//! | [`PartitionedState`] | Hash partitioning for spillable GROUP BY |
//!
//! Async variants (`AsyncSpillManager`, `AsyncSpillFile`) use tokio for
//! non-blocking I/O when running in async contexts.

mod async_file;
mod async_manager;
mod external_sort;
mod file;
mod manager;
mod partition;
mod serializer;

pub use async_file::{AsyncSpillFile, AsyncSpillFileReader};
pub use async_manager::AsyncSpillManager;
pub use external_sort::{ExternalSort, NullOrder, SortDirection, SortKey};
pub use file::{SpillFile, SpillFileReader};
pub use manager::SpillManager;
pub use partition::{DEFAULT_NUM_PARTITIONS, PartitionedState};
pub use serializer::{deserialize_row, deserialize_value, serialize_row, serialize_value};