Struct ChunkSource 

pub struct ChunkSource { /* private fields */ }

Source that produces chunks from a pre-built collection.

Takes ownership of DataChunks and produces them one at a time.

Implementations

impl ChunkSource

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

Create a new chunk source.

pub fn single(chunk: DataChunk) -> Self

Create from a single chunk.

Trait Implementations

impl Source for ChunkSource

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.