Struct ParallelVectorSource 

pub struct ParallelVectorSource { /* private fields */ }

Parallel source wrapper for vector data.

Wraps columnar data in a parallel source that can be partitioned.

Implementations

impl ParallelVectorSource

pub fn new(columns: Vec<Vec<Value>>) -> Self

Creates a new parallel vector source.

pub fn single_column(values: Vec<Value>) -> Self

Creates a single-column source.

Trait Implementations

impl ParallelSource for ParallelVectorSource

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 ParallelVectorSource

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.