linkrs_query/executor/streaming/helpers.rs
1//! Helper modules for streaming executor
2//!
3//! - comparison: value comparison and sorting
4//! - accumulator_states: typed accumulator state for partial+final aggregates
5//! - conversion: data type conversions
6//! - runtime_bridge: runtime-aware await for async coordinator calls
7
8pub mod accumulator_states;
9pub mod comparison;
10pub mod conversion;
11pub mod runtime_bridge;
12
13pub use accumulator_states::{
14 accumulator_to_value, decode_partial, finalize_accumulator_value, AggregateAccumulator,
15};
16pub use comparison::compare_values;
17pub use conversion::{edge_to_row, edges_to_rows, vertex_to_row, vertices_to_rows};