Struct InProgressByteArray 

pub(crate) struct InProgressByteArray<T: ByteArrayType> {
    source: Option<ArrayRef>,
    batch_size: usize,
    direct: GenericByteBuilder<T>,
}

Fields

source: Option<ArrayRef>

batch_size: usize

direct: GenericByteBuilder<T>

Implementations

impl<T: ByteArrayType> InProgressByteArray<T>

where T::Offset: OffsetSizeTrait,

pub(crate) fn new(batch_size: usize) -> Self

fn checked_values_len( current: usize, additional: usize, ) -> Result<usize, ArrowError>

fn ensure_capacity(&mut self, source: &GenericByteArray<T>, rows: usize)

fn append_filter_indices( &mut self, source: &GenericByteArray<T>, indices: FilterIterator<Copied<Iter<'_, usize>>, IndexIterator<'_>>, count: usize, ) -> Result<(), ArrowError>

Trait Implementations

impl<T: ByteArrayType> Debug for InProgressByteArray<T>

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

Formats the value using the given formatter.

impl<T: ByteArrayType + 'static> InProgressArray for InProgressByteArray<T>

where T::Offset: OffsetSizeTrait,

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 a FilterPredicate from source.

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

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

fn size(&self) -> usize

Get the number of bytes this array is using

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.