Trait vortex_array::stream::ArrayStream

pub trait ArrayStream: Stream<Item = VortexResult<ArrayData>> {
    // Required method
    fn dtype(&self) -> &DType;
}

A stream of array chunks along with a DType.

Can be thought of as equivalent to Arrow’s RecordBatchReader.

Required Methods

fn dtype(&self) -> &DType

Implementors

impl<S> ArrayStream for ArrayStreamAdapter<S>

where S: Stream<Item = VortexResult<ArrayData>>,