Struct ParallelBgpEvaluator 

pub struct ParallelBgpEvaluator {
    pub num_threads: usize,
    pub chunk_size: usize,
}

Parallel evaluator for Basic Graph Patterns.

Fields

num_threads: usize

Number of worker threads (0 = use Rayon’s global pool)

chunk_size: usize

Minimum patterns per stage to justify parallelism overhead

Implementations

impl ParallelBgpEvaluator

pub fn new(num_threads: usize) -> Self

Create a new evaluator with a specific thread count

pub fn with_chunk_size(self, chunk_size: usize) -> Self

Create a new evaluator with tunable chunk size

pub fn evaluate( &self, patterns: Vec<TriplePatternInfo>, store: &dyn TripleStore, ) -> Result<Vec<BindingRow>>

Evaluate a BGP by exploiting parallelism among independent patterns.

pub fn merge_results( &self, left: Vec<BindingRow>, right: Vec<BindingRow>, join_vars: &[String], ) -> Vec<BindingRow>

Hash join of two binding sets on shared variables.

Trait Implementations

impl Default for ParallelBgpEvaluator

fn default() -> Self

Returns the “default value” for a type.