Struct PrimitiveBuilder

pub struct PrimitiveBuilder<T: ArrowPrimitiveType> {
    values_builder: BufferBuilder<T::Native>,
    null_buffer_builder: NullBufferBuilder,
    data_type: DataType,
}

Builder for PrimitiveArray

Fields

values_builder: BufferBuilder<T::Native>

null_buffer_builder: NullBufferBuilder

data_type: DataType

Implementations

impl<T: ArrowPrimitiveType> PrimitiveBuilder<T>

pub fn new() -> Self

Creates a new primitive array builder

pub fn with_capacity(capacity: usize) -> Self

Creates a new primitive array builder with capacity no of items

pub fn new_from_buffer( values_buffer: MutableBuffer, null_buffer: Option<MutableBuffer>, ) -> Self

Creates a new primitive array builder from buffers

pub fn with_data_type(self, data_type: DataType) -> Self

By default PrimitiveBuilder uses ArrowPrimitiveType::DATA_TYPE as the data type of the generated array.

This method allows overriding the data type, to allow specifying timezones for [DataType::Timestamp] or precision and scale for [DataType::Decimal128] and [DataType::Decimal256]

Panics

This method panics if data_type is not PrimitiveArray::is_compatible

pub fn capacity(&self) -> usize

Returns the capacity of this builder measured in slots of type T

pub fn append_value(&mut self, v: T::Native)

Appends a value of type T into the builder

pub fn append_value_n(&mut self, v: T::Native, n: usize)

Appends a value of type T into the builder n times

pub fn append_null(&mut self)

Appends a null slot into the builder

pub fn append_nulls(&mut self, n: usize)

Appends n no. of null’s into the builder

pub fn append_option(&mut self, v: Option<T::Native>)

Appends an Option<T> into the builder

pub fn append_slice(&mut self, v: &[T::Native])

Appends a slice of type T into the builder

pub fn append_values(&mut self, values: &[T::Native], is_valid: &[bool])

Appends values from a slice of type T and a validity boolean slice

Panics

Panics if values and is_valid have different lengths

pub fn append_array(&mut self, array: &PrimitiveArray<T>)

Appends array values and null to this builder as is (this means that underlying null values are copied as is).

Panics

Panics if array and self data types are different

pub unsafe fn append_trusted_len_iter( &mut self, iter: impl IntoIterator<Item = T::Native>, )

Appends values from a trusted length iterator.

Safety

This requires the iterator be a trusted length. This could instead require the iterator implement TrustedLen once that is stabilized.

pub fn finish(&mut self) -> PrimitiveArray<T>

Builds the PrimitiveArray and reset this builder.

pub fn finish_cloned(&self) -> PrimitiveArray<T>

Builds the PrimitiveArray without resetting the builder.

pub fn values_slice(&self) -> &[T::Native]

Returns the current values buffer as a slice

pub fn values_slice_mut(&mut self) -> &mut [T::Native]

Returns the current values buffer as a mutable slice

pub fn validity_slice(&self) -> Option<&[u8]>

Returns the current null buffer as a slice

pub fn validity_slice_mut(&mut self) -> Option<&mut [u8]>

Returns the current null buffer as a mutable slice

pub fn slices_mut(&mut self) -> (&mut [T::Native], Option<&mut [u8]>)

Returns the current values buffer and null buffer as a slice

impl<P: DecimalType> PrimitiveBuilder<P>

pub fn with_precision_and_scale( self, precision: u8, scale: i8, ) -> Result<Self, ArrowError>

Sets the precision and scale

impl<P: ArrowTimestampType> PrimitiveBuilder<P>

pub fn with_timezone(self, timezone: impl Into<Arc<str>>) -> Self

Sets the timezone

pub fn with_timezone_opt<S: Into<Arc<str>>>(self, timezone: Option<S>) -> Self

Sets an optional timezone

Trait Implementations

impl<T: ArrowPrimitiveType> ArrayBuilder for PrimitiveBuilder<T>

fn as_any(&self) -> &dyn Any

Returns the builder as a non-mutable Any reference.

fn as_any_mut(&mut self) -> &mut dyn Any

Returns the builder as a mutable Any reference.

fn into_box_any(self: Box<Self>) -> Box<dyn Any>

Returns the boxed builder as a box of Any.

fn len(&self) -> usize

Returns the number of array slots in the builder

fn finish(&mut self) -> ArrayRef

Builds the array and reset this builder.

fn finish_cloned(&self) -> ArrayRef

Builds the array without resetting the builder.

fn is_empty(&self) -> bool

Returns whether number of array slots is zero

impl<T: Debug + ArrowPrimitiveType> Debug for PrimitiveBuilder<T>

where T::Native: Debug,

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

Formats the value using the given formatter.

impl<T: ArrowPrimitiveType> Default for PrimitiveBuilder<T>

fn default() -> Self

Returns the “default value” for a type.

impl<P: ArrowPrimitiveType> Extend<Option<<P as ArrowPrimitiveType>::Native>> for PrimitiveBuilder<P>

fn extend<T: IntoIterator<Item = Option<P::Native>>>(&mut self, iter: T)

Extends a collection with the contents of an iterator.

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.