Struct ParallelChunkSource 

pub struct ParallelChunkSource { /* private fields */ }

Parallel source for pre-built chunks.

Wraps a collection of DataChunks in a parallel source.

Implementations

impl ParallelChunkSource

pub fn new(chunks: Vec<DataChunk>) -> Self

Creates a new parallel chunk source.

Trait Implementations

impl ParallelSource for ParallelChunkSource

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 ParallelChunkSource

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.