Trait vortex_array::stream::ArrayStreamExt

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

Provided Methods

fn into_array_data(self) -> impl Future<Output = VortexResult<ArrayData>>

where Self: Sized,

Collect the stream into a single ArrayData.

If the stream yields multiple chunks, they will be returned as a ChunkedArray.

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

where Self: Sized,

Perform a row-wise selection on the stream from an array of sorted indicessss.

Implementors

impl<S: ArrayStream> ArrayStreamExt for S