Struct arrow2::array::PrimitiveArray

pub struct PrimitiveArray<T: NativeType> { /* fields omitted */ }

A PrimitiveArray is arrow’s equivalent to Vec<Option<T: NativeType>>, i.e. an array designed for highly performant operations on optionally nullable slots, backed by a physical type of a fixed byte-width, such as i32 or f64. The size of this struct is O(1) as all data is stored behind an std::sync::Arc.

Example

use arrow2::array::{PrimitiveArray, Array};
use arrow2::bitmap::Bitmap;
let array = PrimitiveArray::from([Some(1), None, Some(10)]);
assert_eq!(array.values().as_slice(), &[1, 0, 10]);
assert_eq!(array.validity(), Some(&Bitmap::from([true, false, true])));

Implementations

impl<T: NativeType + NaturalDataType> PrimitiveArray<T>

pub fn from_values<I: IntoIterator<Item = T>>(iter: I) -> Self

Creates a (non-null) PrimitiveArray from an iterator of values.

Implementation

This does not assume that the iterator has a known length.

pub fn from_slice<P: AsRef<[T]>>(slice: P) -> Self

Creates a (non-null) PrimitiveArray from a slice of values.

Implementation

This is essentially a memcopy and is the fastest way to create a PrimitiveArray.

impl<T: NativeType + NaturalDataType> PrimitiveArray<T>

pub fn from_trusted_len_values_iter<I: TrustedLen<Item = T>>(iter: I) -> Self

Creates a (non-null) PrimitiveArray from a TrustedLen of values.

Implementation

This does not assume that the iterator has a known length.

pub unsafe fn from_trusted_len_values_iter_unchecked<I: Iterator<Item = T>>(
    iter: I
) -> Self

Creates a new PrimitiveArray from an iterator over values

Safety

The iterator must be TrustedLen. I.e. that size_hint().1 correctly reports its length.

pub fn from_trusted_len_iter<I: TrustedLen<Item = Option<T>>>(iter: I) -> Self

Creates a PrimitiveArray from a TrustedLen of optional values.

pub unsafe fn from_trusted_len_iter_unchecked<I: Iterator<Item = Option<T>>>(
    iter: I
) -> Self

Creates a PrimitiveArray from an iterator of optional values.

Safety

The iterator must be TrustedLen. I.e. that size_hint().1 correctly reports its length.

impl<'a, T: NativeType> PrimitiveArray<T>

pub fn iter(&'a self) -> ZipValidity<'a, &'a T, Iter<'a, T>>

constructs a new iterator

impl<T: NativeType> PrimitiveArray<T>

pub fn new_empty(data_type: DataType) -> Self

Returns a new empty PrimitiveArray.

pub fn new_null(data_type: DataType, length: usize) -> Self

Returns a new PrimitiveArray whose all slots are null / None.

pub fn from_data(
    data_type: DataType,
    values: Buffer<T>,
    validity: Option<Bitmap>
) -> Self

The canonical method to create a PrimitiveArray out of low-end APIs.

Panics

This function panics iff:

• data_type is not supported by the physical type
• The validity is not None and its length is different from the values’s length

pub fn slice(&self, offset: usize, length: usize) -> Self

Returns a slice of this PrimitiveArray.

Implementation

This operation is O(1) as it amounts to increase two ref counts.

Panic

This function panics iff offset + length >= self.len().

pub unsafe fn slice_unchecked(&self, offset: usize, length: usize) -> Self

Returns a slice of this PrimitiveArray.

Implementation

This operation is O(1) as it amounts to increase two ref counts.

Safety

The caller must ensure that offset + length <= self.len().

pub fn with_validity(&self, validity: Option<Bitmap>) -> Self

Sets the validity bitmap on this PrimitiveArray.

Panics

This function panics iff validity.len() != self.len().

pub fn validity(&self) -> Option<&Bitmap>

The optional validity.

pub fn values(&self) -> &Buffer<T>

The values Buffer. Values on null slots are undetermined (they can be anything).

pub fn value(&self, i: usize) -> T

Returns the value at slot i. Equivalent to self.values()[i]. The value on null slots is undetermined (it can be anything).

pub unsafe fn value_unchecked(&self, i: usize) -> T

Returns the element at index i as T. The value on null slots is undetermined (it can be anything).

Safety

Caller must be sure that i < self.len()

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

Returns a new PrimitiveArray with a different logical type. This is O(1).

Panics

Panics iff the data_type is not supported for the physical type.

Trait Implementations

impl<T: NativeType> Array for PrimitiveArray<T>

fn as_any(&self) -> &dyn Any

Convert to trait object.

fn len(&self) -> usize

The length of the Array. Every array has a length corresponding to the number of elements (slots).

fn data_type(&self) -> &DataType

The DataType of the Array. In combination with Array::as_any, this can be used to downcast trait objects (dyn Array) to concrete arrays.

fn validity(&self) -> Option<&Bitmap>

The validity of the Array: every array has an optional Bitmap that, when available specifies whether the array slot is valid or not (null). When the validity is None, all slots are valid.

fn slice(&self, offset: usize, length: usize) -> Box<dyn Array>

Slices the Array, returning a new Box<dyn Array>.

unsafe fn slice_unchecked(&self, offset: usize, length: usize) -> Box<dyn Array>

Slices the Array, returning a new Box<dyn Array>.

fn with_validity(&self, validity: Option<Bitmap>) -> Box<dyn Array>

Sets the validity bitmap on this Array.

fn is_empty(&self) -> bool

whether the array is empty

fn null_count(&self) -> usize

The number of null slots on this Array.

fn is_null(&self, i: usize) -> bool

Returns whether slot i is null.

fn is_valid(&self, i: usize) -> bool

Returns whether slot i is valid.

impl<T> ArrayAdd<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + Add<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn add(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayAdd<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn add(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayAdd<T> for PrimitiveArray<T> where
    T: NativeType + Add<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn add(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayCheckedAdd<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + CheckedAdd<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_add(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayCheckedAdd<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn checked_add(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayCheckedAdd<T> for PrimitiveArray<T> where
    T: NativeType + CheckedAdd<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_add(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayCheckedDiv<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + CheckedDiv<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_div(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayCheckedDiv<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn checked_div(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayCheckedDiv<T> for PrimitiveArray<T> where
    T: NativeType + CheckedDiv<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_div(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayCheckedMul<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + CheckedMul<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_mul(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayCheckedMul<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn checked_mul(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayCheckedMul<T> for PrimitiveArray<T> where
    T: NativeType + CheckedMul<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_mul(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayCheckedRem<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + CheckedRem<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_rem(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl<T> ArrayCheckedRem<T> for PrimitiveArray<T> where
    T: NativeType + CheckedRem<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_rem(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayCheckedSub<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + CheckedSub<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_sub(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayCheckedSub<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn checked_sub(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayCheckedSub<T> for PrimitiveArray<T> where
    T: NativeType + CheckedSub<Output = T> + Zero + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn checked_sub(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayDiv<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + Div<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn div(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayDiv<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn div(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayDiv<T> for PrimitiveArray<T> where
    T: NativeType + Div<Output = T> + NotI128 + NumCast, 

This is supported on crate feature compute only.

type Output = Self

fn div(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayMul<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + Mul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn mul(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArrayMul<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn mul(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArrayMul<T> for PrimitiveArray<T> where
    T: NativeType + Mul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn mul(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayOverflowingAdd<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + OverflowingAdd<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_add(
    &self,
    rhs: &PrimitiveArray<T>
) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayOverflowingAdd<T> for PrimitiveArray<T> where
    T: NativeType + OverflowingAdd<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_add(&self, rhs: &T) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayOverflowingMul<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + OverflowingMul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_mul(
    &self,
    rhs: &PrimitiveArray<T>
) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayOverflowingMul<T> for PrimitiveArray<T> where
    T: NativeType + OverflowingMul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_mul(&self, rhs: &T) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayOverflowingSub<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + OverflowingSub<Output = T>, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_sub(
    &self,
    rhs: &PrimitiveArray<T>
) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayOverflowingSub<T> for PrimitiveArray<T> where
    T: NativeType + OverflowingSub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn overflowing_sub(&self, rhs: &T) -> Result<(Self::Output, Bitmap)>

impl<T> ArrayRem<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + Rem<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn rem(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl<T> ArrayRem<T> for PrimitiveArray<T> where
    T: NativeType + Rem<Output = T> + NotI128 + NumCast, 

This is supported on crate feature compute only.

type Output = Self

fn rem(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArraySaturatingAdd<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + SaturatingAdd<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_add(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArraySaturatingAdd<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn saturating_add(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArraySaturatingAdd<T> for PrimitiveArray<T> where
    T: NativeType + SaturatingAdd<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_add(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArraySaturatingMul<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + SaturatingMul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_mul(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArraySaturatingMul<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn saturating_mul(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArraySaturatingMul<T> for PrimitiveArray<T> where
    T: NativeType + SaturatingMul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_mul(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArraySaturatingSub<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + SaturatingSub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_sub(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArraySaturatingSub<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn saturating_sub(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArraySaturatingSub<T> for PrimitiveArray<T> where
    T: NativeType + SaturatingSub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn saturating_sub(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArraySub<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + Sub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn sub(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl ArraySub<PrimitiveArray<i128>> for PrimitiveArray<i128>

This is supported on crate feature compute only.

type Output = Self

fn sub(&self, rhs: &PrimitiveArray<i128>) -> Result<Self::Output>

impl<T> ArraySub<T> for PrimitiveArray<T> where
    T: NativeType + Sub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn sub(&self, rhs: &T) -> Result<Self::Output>

impl<T> ArrayWrappingAdd<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + WrappingAdd<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn wrapping_add(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl<T> ArrayWrappingMul<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + WrappingMul<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn wrapping_mul(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl<T> ArrayWrappingSub<PrimitiveArray<T>> for PrimitiveArray<T> where
    T: NativeType + WrappingSub<Output = T> + NotI128, 

This is supported on crate feature compute only.

type Output = Self

fn wrapping_sub(&self, rhs: &PrimitiveArray<T>) -> Result<Self::Output>

impl<T: Clone + NativeType> Clone for PrimitiveArray<T>

fn clone(&self) -> PrimitiveArray<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + NativeType> Debug for PrimitiveArray<T>

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

Formats the value using the given formatter.

impl<T: NativeType> Display for PrimitiveArray<T>

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

Formats the value using the given formatter.

impl<'a, T: NativeType> From<GrowablePrimitive<'a, T>> for PrimitiveArray<T>

fn from(val: GrowablePrimitive<'a, T>) -> Self

Performs the conversion.

impl<T: NativeType> From<MutablePrimitiveArray<T>> for PrimitiveArray<T>

fn from(other: MutablePrimitiveArray<T>) -> Self

Performs the conversion.

impl<T: NativeType + NaturalDataType, P: AsRef<[Option<T>]>> From<P> for PrimitiveArray<T>

fn from(slice: P) -> Self

Performs the conversion.

impl<T: NativeType, A: ArrowArrayRef> FromFfi<A> for PrimitiveArray<T>

unsafe fn try_from_ffi(array: A) -> Result<Self>

Convert itself from FFI.

impl<T: NativeType + NaturalDataType, Ptr: Borrow<Option<T>>> FromIterator<Ptr> for PrimitiveArray<T>

fn from_iter<I: IntoIterator<Item = Ptr>>(iter: I) -> Self

Creates a value from an iterator.

impl<'a, T: NativeType> IntoIterator for &'a PrimitiveArray<T>

type Item = Option<&'a T>

The type of the elements being iterated over.

type IntoIter = ZipValidity<'a, &'a T, Iter<'a, T>>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<T: NativeType> PartialEq<&'_ (dyn Array + '_)> for PrimitiveArray<T>

fn eq(&self, other: &&dyn Array) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl<T: NativeType> PartialEq<PrimitiveArray<T>> for PrimitiveArray<T>

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl<T: NativeType> ToFfi for PrimitiveArray<T>

fn buffers(&self) -> Vec<Option<NonNull<u8>>>

The pointers to the buffers.

fn offset(&self) -> usize

The offset

fn children(&self) -> Vec<Arc<dyn Array>>

The children