Struct GenericInProgressArray 

pub(crate) struct GenericInProgressArray {
    source: Option<ArrayRef>,
    buffered_arrays: Vec<ArrayRef>,
}

Generic implementation for InProgressArray that works with any type of array.

Internally, this buffers arrays and then calls other kernels such as concat to produce the final array.

Fields

source: Option<ArrayRef>

The current source

buffered_arrays: Vec<ArrayRef>

The buffered array slices

Implementations

impl GenericInProgressArray

pub(crate) fn new() -> Self

Create a new GenericInProgressArray

Trait Implementations

impl Debug for GenericInProgressArray

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl InProgressArray for GenericInProgressArray

fn set_source(&mut self, source: Option<ArrayRef>)

Set the source array.

fn copy_rows(&mut self, offset: usize, len: usize) -> Result<(), ArrowError>

Copy rows from the current source array into the in-progress array

fn copy_rows_by_filter_from( &mut self, source: ArrayRef, filter: &FilterPredicate, ) -> Result<(), ArrowError>

Copy rows selected by filter from source.

fn finish(&mut self) -> Result<ArrayRef, ArrowError>

Finish the currently in-progress array and return it as an ArrayRef

fn copy_rows_by_filter( &mut self, filter: &FilterPredicate, ) -> Result<(), ArrowError>

Copy rows selected by filter from the current source array.

fn copy_rows_by_selection( &mut self, selection: FilterSelection<'_>, ) -> Result<(), ArrowError>

Copy rows described by a FilterSelection from the current source array.