Struct ParallelNodeScanSource 

pub struct ParallelNodeScanSource { /* private fields */ }

Parallel source for scanning nodes from the LPG store.

Enables morsel-driven parallel execution of node scans by label. Each partition independently scans a range of node IDs, enabling linear scaling on multi-core systems for large datasets.

Example

use grafeo_core::execution::parallel::{ParallelNodeScanSource, ParallelSource};
use grafeo_core::graph::lpg::LpgStore;
use std::sync::Arc;

let store = Arc::new(LpgStore::new().unwrap());
// ... populate store ...

// Scan all Person nodes in parallel
let source = ParallelNodeScanSource::with_label(store, "Person");
let morsels = source.generate_morsels(4096, 0);

Implementations

impl ParallelNodeScanSource

pub fn new(store: Arc<dyn GraphStore>) -> Self

Creates a parallel source for all nodes in the store.

pub fn with_label(store: Arc<dyn GraphStore>, label: &str) -> Self

Creates a parallel source for nodes with a specific label.

pub fn from_node_ids(store: Arc<dyn GraphStore>, node_ids: Vec<NodeId>) -> Self

Creates from pre-computed node IDs.

Useful when node IDs are already available from a previous operation.

pub fn store(&self) -> &Arc<dyn GraphStore>

Returns the underlying store reference.

Trait Implementations

impl ParallelSource for ParallelNodeScanSource

fn total_rows(&self) -> Option<usize>

Returns the total number of rows in this source, if known.

fn create_partition(&self, morsel: &Morsel) -> Box<dyn Source>

Creates a partition source for the given morsel.

fn num_columns(&self) -> usize

Returns the number of columns in this source.

fn is_partitionable(&self) -> bool

Returns whether this source can be partitioned.

fn generate_morsels(&self, morsel_size: usize, source_id: usize) -> Vec<Morsel>

Generates morsels that cover all rows in this source.

impl Source for ParallelNodeScanSource

fn next_chunk( &mut self, chunk_size: usize, ) -> Result<Option<DataChunk>, OperatorError>

Produce the next chunk of data.

fn reset(&mut self)

Reset the source to its initial state.

fn name(&self) -> &'static str

Name of this source for debugging.