vortex_array::stream

Trait ArrayStreamExt

Source 
pub trait ArrayStreamExt: ArrayStream {
    // Provided methods
    fn boxed(self) -> SendableArrayStream
       where Self: Sized + Send + 'static { ... }
    fn read_all(self) -> impl Future<Output = VortexResult<ArrayRef>>
       where Self: Sized { ... }
    fn take_rows(self, indices: ArrayRef) -> VortexResult<impl ArrayStream>
       where Self: Sized { ... }
}

Provided Methods§

Source

fn boxed(self) -> SendableArrayStream
where Self: Sized + Send + 'static,

Box the ArrayStream so that it can be sent between threads.

Source

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

Collect the stream into a single Array.

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

Source

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

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

Implementors§