Struct ByteViewGroupValueBuilder 

pub struct ByteViewGroupValueBuilder<B>
where
    B: ByteViewType,
{
    views: Vec<u128>,
    in_progress: Vec<u8>,
    completed: Vec<Buffer>,
    max_block_size: usize,
    nulls: MaybeNullBufferBuilder,
    _phantom: PhantomData<B>,
}

An implementation of GroupColumn for binary view and utf8 view types.

Stores a collection of binary view or utf8 view group values in a buffer whose structure is similar to GenericByteViewArray, and we can get benefits:

1. Efficient comparison of incoming rows to existing rows
2. Efficient construction of the final output array
3. Efficient to perform take_n comparing to use GenericByteViewBuilder

Fields

views: Vec<u128>

in_progress: Vec<u8>

completed: Vec<Buffer>

max_block_size: usize

nulls: MaybeNullBufferBuilder

_phantom: PhantomData<B>

Implementations

impl<B> ByteViewGroupValueBuilder<B>

where B: ByteViewType,

pub fn new() -> ByteViewGroupValueBuilder<B>

Trait Implementations

impl<B> Default for ByteViewGroupValueBuilder<B>

where B: ByteViewType,

fn default() -> ByteViewGroupValueBuilder<B>

Returns the “default value” for a type.

impl<B> GroupColumn for ByteViewGroupValueBuilder<B>

where B: ByteViewType,

fn equal_to( &self, lhs_row: usize, array: &Arc<dyn Array>, rhs_row: usize, ) -> bool

Returns equal if the row stored in this builder at lhs_row is equal to the row in array at rhs_row

fn append_val( &mut self, array: &Arc<dyn Array>, row: usize, ) -> Result<(), DataFusionError>

Appends the row at row in array to this builder

fn vectorized_equal_to( &self, group_indices: &[usize], array: &Arc<dyn Array>, rows: &[usize], equal_to_results: &mut [bool], )

The vectorized version equal to

fn vectorized_append( &mut self, array: &Arc<dyn Array>, rows: &[usize], ) -> Result<(), DataFusionError>

The vectorized version append_val

fn len(&self) -> usize

Returns the number of rows stored in this builder

fn size(&self) -> usize

Returns the number of bytes used by this GroupColumn

fn build(self: Box<ByteViewGroupValueBuilder<B>>) -> Arc<dyn Array>

Builds a new array from all of the stored rows

fn take_n(&mut self, n: usize) -> Arc<dyn Array>

Builds a new array from the first n stored rows, shifting the remaining rows to the start of the builder

fn is_empty(&self) -> bool

true if len == 0