pub struct PrimitiveDictionaryBuilder<K, V>where
K: ArrowPrimitiveType,
V: ArrowPrimitiveType,{ /* private fields */ }
Expand description
Builder for DictionaryArray
of PrimitiveArray
§Example:
let mut builder = PrimitiveDictionaryBuilder::<UInt8Type, UInt32Type>::new();
builder.append(12345678).unwrap();
builder.append_null();
builder.append(22345678).unwrap();
let array = builder.finish();
assert_eq!(
array.keys(),
&UInt8Array::from(vec![Some(0), None, Some(1)])
);
// Values are polymorphic and so require a downcast.
let av = array.values();
let ava: &UInt32Array = av.as_any().downcast_ref::<UInt32Array>().unwrap();
let avs: &[u32] = ava.values();
assert!(!array.is_null(0));
assert!(array.is_null(1));
assert!(!array.is_null(2));
assert_eq!(avs, &[12345678, 22345678]);
Implementations§
Source§impl<K, V> PrimitiveDictionaryBuilder<K, V>where
K: ArrowPrimitiveType,
V: ArrowPrimitiveType,
impl<K, V> PrimitiveDictionaryBuilder<K, V>where
K: ArrowPrimitiveType,
V: ArrowPrimitiveType,
Sourcepub fn new_from_empty_builders(
keys_builder: PrimitiveBuilder<K>,
values_builder: PrimitiveBuilder<V>,
) -> Self
pub fn new_from_empty_builders( keys_builder: PrimitiveBuilder<K>, values_builder: PrimitiveBuilder<V>, ) -> Self
Creates a new PrimitiveDictionaryBuilder
from the provided keys and values builders.
§Panics
This method panics if keys_builder
or values_builder
is not empty.
Sourcepub unsafe fn new_from_builders(
keys_builder: PrimitiveBuilder<K>,
values_builder: PrimitiveBuilder<V>,
) -> Self
pub unsafe fn new_from_builders( keys_builder: PrimitiveBuilder<K>, values_builder: PrimitiveBuilder<V>, ) -> Self
Creates a new PrimitiveDictionaryBuilder
from existing PrimitiveBuilder
s of keys and values.
§Safety
caller must ensure that the passed in builders are valid for DictionaryArray.
Sourcepub fn with_capacity(keys_capacity: usize, values_capacity: usize) -> Self
pub fn with_capacity(keys_capacity: usize, values_capacity: usize) -> Self
Creates a new PrimitiveDictionaryBuilder
with the provided capacities
keys_capacity
: the number of keys, i.e. length of array to build
values_capacity
: the number of distinct dictionary values, i.e. size of dictionary
Source§impl<K, V> PrimitiveDictionaryBuilder<K, V>where
K: ArrowDictionaryKeyType,
V: ArrowPrimitiveType,
impl<K, V> PrimitiveDictionaryBuilder<K, V>where
K: ArrowDictionaryKeyType,
V: ArrowPrimitiveType,
Sourcepub fn append(&mut self, value: V::Native) -> Result<K::Native, ArrowError>
pub fn append(&mut self, value: V::Native) -> Result<K::Native, ArrowError>
Append a primitive value to the array. Return an existing index if already present in the values array or a new index if the value is appended to the values array.
Sourcepub fn append_n(
&mut self,
value: V::Native,
count: usize,
) -> Result<K::Native, ArrowError>
pub fn append_n( &mut self, value: V::Native, count: usize, ) -> Result<K::Native, ArrowError>
Append a value multiple times to the array.
This is the same as append
but allows to append the same value multiple times without doing multiple lookups.
Returns an error if the new index would overflow the key type.
Sourcepub fn append_value(&mut self, value: V::Native)
pub fn append_value(&mut self, value: V::Native)
Infallibly append a value to this builder
§Panics
Panics if the resulting length of the dictionary values array would exceed T::Native::MAX
Sourcepub fn append_values(&mut self, value: V::Native, count: usize)
pub fn append_values(&mut self, value: V::Native, count: usize)
Infallibly append a value to this builder repeatedly count
times.
This is the same as append_value
but allows to append the same value multiple times without doing multiple lookups.
§Panics
Panics if the resulting length of the dictionary values array would exceed T::Native::MAX
Sourcepub fn append_null(&mut self)
pub fn append_null(&mut self)
Appends a null slot into the builder
Sourcepub fn append_nulls(&mut self, n: usize)
pub fn append_nulls(&mut self, n: usize)
Append n
null slots into the builder
Sourcepub fn append_option(&mut self, value: Option<V::Native>)
pub fn append_option(&mut self, value: Option<V::Native>)
Append an Option
value into the builder
§Panics
Panics if the resulting length of the dictionary values array would exceed T::Native::MAX
Sourcepub fn append_options(&mut self, value: Option<V::Native>, count: usize)
pub fn append_options(&mut self, value: Option<V::Native>, count: usize)
Append an Option
value into the builder repeatedly count
times.
This is the same as append_option
but allows to append the same value multiple times without doing multiple lookups.
§Panics
Panics if the resulting length of the dictionary values array would exceed T::Native::MAX
Sourcepub fn finish(&mut self) -> DictionaryArray<K>
pub fn finish(&mut self) -> DictionaryArray<K>
Builds the DictionaryArray
and reset this builder.
Sourcepub fn finish_cloned(&self) -> DictionaryArray<K>
pub fn finish_cloned(&self) -> DictionaryArray<K>
Builds the DictionaryArray
without resetting the builder.
Sourcepub fn values_slice(&self) -> &[V::Native]
pub fn values_slice(&self) -> &[V::Native]
Returns the current dictionary values buffer as a slice
Sourcepub fn values_slice_mut(&mut self) -> &mut [V::Native]
pub fn values_slice_mut(&mut self) -> &mut [V::Native]
Returns the current dictionary values buffer as a mutable slice
Sourcepub fn validity_slice(&self) -> Option<&[u8]>
pub fn validity_slice(&self) -> Option<&[u8]>
Returns the current null buffer as a slice
Trait Implementations§
Source§impl<K, V> ArrayBuilder for PrimitiveDictionaryBuilder<K, V>where
K: ArrowDictionaryKeyType,
V: ArrowPrimitiveType,
impl<K, V> ArrayBuilder for PrimitiveDictionaryBuilder<K, V>where
K: ArrowDictionaryKeyType,
V: ArrowPrimitiveType,
Source§fn as_any_mut(&mut self) -> &mut dyn Any
fn as_any_mut(&mut self) -> &mut dyn Any
Returns the builder as an mutable Any
reference.
Source§fn finish_cloned(&self) -> ArrayRef
fn finish_cloned(&self) -> ArrayRef
Builds the array without resetting the builder.
Source§impl<K, V> Debug for PrimitiveDictionaryBuilder<K, V>
impl<K, V> Debug for PrimitiveDictionaryBuilder<K, V>
Source§impl<K, V> Default for PrimitiveDictionaryBuilder<K, V>where
K: ArrowPrimitiveType,
V: ArrowPrimitiveType,
impl<K, V> Default for PrimitiveDictionaryBuilder<K, V>where
K: ArrowPrimitiveType,
V: ArrowPrimitiveType,
Source§impl<K: ArrowDictionaryKeyType, P: ArrowPrimitiveType> Extend<Option<<P as ArrowPrimitiveType>::Native>> for PrimitiveDictionaryBuilder<K, P>
impl<K: ArrowDictionaryKeyType, P: ArrowPrimitiveType> Extend<Option<<P as ArrowPrimitiveType>::Native>> for PrimitiveDictionaryBuilder<K, P>
Source§fn extend<T: IntoIterator<Item = Option<P::Native>>>(&mut self, iter: T)
fn extend<T: IntoIterator<Item = Option<P::Native>>>(&mut self, iter: T)
Source§fn extend_one(&mut self, item: A)
fn extend_one(&mut self, item: A)
extend_one
)Source§fn extend_reserve(&mut self, additional: usize)
fn extend_reserve(&mut self, additional: usize)
extend_one
)