Struct ByteGroupValueBuilder 

pub struct ByteGroupValueBuilder<O>
where
    O: OffsetSizeTrait,
{
    output_type: OutputType,
    buffer: BufferBuilder<u8>,
    offsets: Vec<O>,
    nulls: MaybeNullBufferBuilder,
    max_buffer_size: usize,
}

An implementation of GroupColumn for binary and utf8 types.

Stores a collection of binary or utf8 group values in a single buffer in a way that allows:

1. Efficient comparison of incoming rows to existing rows
2. Efficient construction of the final output array

Fields

output_type: OutputType

buffer: BufferBuilder<u8>

offsets: Vec<O>

Offsets into buffer for each distinct value. These offsets as used directly to create the final GenericBinaryArray. The ith string is stored in the range offsets[i]..offsets[i+1] in buffer. Null values are stored as a zero length string.

nulls: MaybeNullBufferBuilder

Nulls

max_buffer_size: usize

The maximum size of the buffer for 0

Implementations

impl<O> ByteGroupValueBuilder<O>

where O: OffsetSizeTrait,

pub fn new(output_type: OutputType) -> Self

fn equal_to_inner<B>( &self, lhs_row: usize, array: &ArrayRef, rhs_row: usize, ) -> bool

where B: ByteArrayType,

fn append_val_inner<B>(&mut self, array: &ArrayRef, row: usize) -> Result<()>

where B: ByteArrayType,

fn vectorized_equal_to_inner<B>( &self, lhs_rows: &[usize], array: &ArrayRef, rhs_rows: &[usize], equal_to_results: &mut [bool], )

where B: ByteArrayType,

fn vectorized_append_inner<B>( &mut self, array: &ArrayRef, rows: &[usize], ) -> Result<()>

where B: ByteArrayType,

fn do_equal_to_inner<B>( &self, lhs_row: usize, array: &GenericByteArray<B>, rhs_row: usize, ) -> bool

where B: ByteArrayType,

fn do_append_val_inner<B>( &mut self, array: &GenericByteArray<B>, row: usize, ) -> Result<()>

where B: ByteArrayType,

pub fn value(&self, row: usize) -> &[u8]

return the current value of the specified row irrespective of null

Trait Implementations

impl<O> GroupColumn for ByteGroupValueBuilder<O>

where O: OffsetSizeTrait,

fn equal_to(&self, lhs_row: usize, column: &ArrayRef, 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, column: &ArrayRef, row: usize) -> Result<()>

Appends the row at row in array to this builder

fn vectorized_equal_to( &self, lhs_rows: &[usize], array: &ArrayRef, rhs_rows: &[usize], equal_to_results: &mut [bool], )

The vectorized version equal to

fn vectorized_append(&mut self, column: &ArrayRef, rows: &[usize]) -> Result<()>

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<Self>) -> ArrayRef

Builds a new array from all of the stored rows

fn take_n(&mut self, n: usize) -> ArrayRef

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