vortex_array::stream

Trait ArrayStreamExt

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

Provided Methods§

Source

fn collect_chunked(self) -> impl Future<Output = VortexResult<ChunkedArray>>
where Self: Sized,

Source

fn take_rows(self, indices: ArrayData) -> VortexResult<impl ArrayStream>
where Self: Sized,

Implementors§