Trait vortex::stream::ArrayStreamExt

pub trait ArrayStreamExt: ArrayStream {
    // Provided methods
    fn collect_chunked(self) -> impl Future<Output = VortexResult<ChunkedArray>>
       where Self: Sized { ... }
    fn take_rows(self, indices: Array) -> VortexResult<impl ArrayStream>
       where Self: Sized { ... }
}

Provided Methods

fn collect_chunked(self) -> impl Future<Output = VortexResult<ChunkedArray>>

where Self: Sized,

fn take_rows(self, indices: Array) -> VortexResult<impl ArrayStream>

where Self: Sized,

Implementors

impl<R: ArrayStream> ArrayStreamExt for R