Struct RangeSource 

pub struct RangeSource { /* private fields */ }

Generates a range source for parallel execution testing.

Produces integers from 0 to n-1 in a single column.

Implementations

impl RangeSource

pub fn new(total: usize) -> Self

Creates a new range source.

Trait Implementations

impl ParallelSource for RangeSource

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 RangeSource

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.