Struct PartitionView 

pub struct PartitionView {
    pub partition_count: usize,
    pub partition_ids: Vec<usize>,
    pub partition_ranges: Vec<Range<i64>>,
}

A view of data partitioned for parallel processing

Partitions allow executor to process data independently, enabling parallel execution across CPU cores.

Fields

partition_count: usize

Total number of partitions

partition_ids: Vec<usize>

IDs of all partitions

partition_ranges: Vec<Range<i64>>

Range of items (e.g., vertex IDs) for each partition

Implementations

impl PartitionView

pub fn try_new( partition_count: usize, partition_ranges: Vec<Range<i64>>, ) -> Result<Self, QueryError>

Create a validated partition view.

pub fn single(range: Range<i64>) -> Result<Self, QueryError>

Create a single partition (no partitioning)

pub fn from_range( range: Range<i64>, partition_count: usize, ) -> Result<Self, QueryError>

Split a range into N partitions

pub fn get_range(&self, partition_id: usize) -> Option<Range<i64>>

Get the range for a specific partition

pub fn partition_size(&self, partition_id: usize) -> i64

Number of items in a specific partition

pub fn total_size(&self) -> i64

Total number of items across all partitions

Trait Implementations

impl Clone for PartitionView

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PartitionView

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<&PartitionSpec> for PartitionView

Infallible conversion from a validated PartitionSpec. Skips re-validation because PartitionSpec::try_new() already guarantees non-empty, ordered, non-overlapping ranges.

fn from(spec: &PartitionSpec) -> Self

Converts to this type from the input type.