Expand description
Helper modules for streaming executor
- comparison: value comparison and sorting
- accumulator_states: typed accumulator state for partial+final aggregates
- conversion: data type conversions
- runtime_bridge: runtime-aware await for async coordinator calls
Re-exports§
pub use accumulator_states::accumulator_to_value;pub use accumulator_states::decode_partial;pub use accumulator_states::finalize_accumulator_value;pub use accumulator_states::AggregateAccumulator;pub use comparison::compare_values;pub use conversion::edge_to_row;pub use conversion::edges_to_rows;pub use conversion::vertex_to_row;pub use conversion::vertices_to_rows;
Modules§
- accumulator_
states - comparison
- Value comparison for sorting
- conversion
- Data type conversions for streaming executor
- runtime_
bridge - Bridge for awaiting async coordinator operations from operator threads.