pub struct MutablePrimitiveArray<T>
where T: NativeType,
{ data_type: DataType, values: Vec<T>, validity: Option<MutableBitmap>, }
Expand description

The Arrow’s equivalent to Vec<Option<T>> where T is byte-size (e.g. i32). Converting a MutablePrimitiveArray into a PrimitiveArray is O(1).

Fields§

§data_type: DataType§values: Vec<T>§validity: Option<MutableBitmap>

Implementations§

§

impl<'a, T> MutablePrimitiveArray<T>
where T: NativeType,

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

Returns an iterator over Option<T>

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

Returns an iterator of T

§

impl<T> MutablePrimitiveArray<T>
where T: NativeType,

pub fn new() -> MutablePrimitiveArray<T>

Creates a new empty MutablePrimitiveArray.

pub fn with_capacity(capacity: usize) -> MutablePrimitiveArray<T>

Creates a new MutablePrimitiveArray with a capacity.

pub fn try_new( data_type: DataType, values: Vec<T>, validity: Option<MutableBitmap> ) -> Result<MutablePrimitiveArray<T>, Error>

The canonical method to create a MutablePrimitiveArray out of its internal components.

§Implementation

This function is O(1).

§Errors

This function errors iff:

  • The validity is not None and its length is different from values’s length
  • The data_type’s crate::datatypes::PhysicalType is not equal to [crate::datatypes::PhysicalType::Primitive(T::PRIMITIVE)]

pub fn into_inner(self) -> (DataType, Vec<T>, Option<MutableBitmap>)

Extract the low-end APIs from the MutablePrimitiveArray.

pub fn apply_values<F>(&mut self, f: F)
where F: Fn(&mut [T]),

Applies a function f to the values of this array, cloning the values iff they are being shared with others

This is an API to use clone-on-write

§Implementation

This function is O(f) if the data is not being shared, and O(N) + O(f) if it is being shared (since it results in a O(N) memcopy).

§Panics

This function panics iff f panics

§

impl<T> MutablePrimitiveArray<T>
where T: NativeType,

pub fn with_capacity_from( capacity: usize, data_type: DataType ) -> MutablePrimitiveArray<T>

Creates a new MutablePrimitiveArray from a capacity and DataType.

pub fn reserve(&mut self, additional: usize)

Reserves additional entries.

pub fn push(&mut self, value: Option<T>)

Adds a new value to the array.

pub fn pop(&mut self) -> Option<T>

Pop a value from the array. Note if the values is empty, this method will return None.

pub fn extend_constant(&mut self, additional: usize, value: Option<T>)

Extends the MutablePrimitiveArray with a constant

pub fn extend_trusted_len<P, I>(&mut self, iterator: I)
where P: Borrow<T>, I: TrustedLen<Item = Option<P>>,

Extends the MutablePrimitiveArray from an iterator of trusted len.

pub unsafe fn extend_trusted_len_unchecked<P, I>(&mut self, iterator: I)
where P: Borrow<T>, I: Iterator<Item = Option<P>>,

Extends the MutablePrimitiveArray from an iterator of trusted len.

§Safety

The iterator must be trusted len.

pub fn extend_trusted_len_values<I>(&mut self, iterator: I)
where I: TrustedLen<Item = T>,

Extends the MutablePrimitiveArray from an iterator of values of trusted len. This differs from extend_trusted_len which accepts in iterator of optional values.

pub unsafe fn extend_trusted_len_values_unchecked<I>(&mut self, iterator: I)
where I: Iterator<Item = T>,

Extends the MutablePrimitiveArray from an iterator of values of trusted len. This differs from extend_trusted_len_unchecked which accepts in iterator of optional values.

§Safety

The iterator must be trusted len.

pub fn extend_from_slice(&mut self, items: &[T])

Extends the MutablePrimitiveArray from a slice

pub fn to(self, data_type: DataType) -> MutablePrimitiveArray<T>

Changes the arrays’ DataType, returning a new MutablePrimitiveArray. Use to change the logical type without changing the corresponding physical Type.

§Implementation

This operation is O(1).

pub fn into_arc(self) -> Arc<dyn Array>

Converts itself into an Array.

pub fn shrink_to_fit(&mut self)

Shrinks the capacity of the MutablePrimitiveArray to fit its current length.

pub fn capacity(&self) -> usize

Returns the capacity of this MutablePrimitiveArray.

§

impl<T> MutablePrimitiveArray<T>
where T: NativeType,

Accessors

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

Returns its values.

pub fn values_mut_slice(&mut self) -> &mut [T]

Returns a mutable slice of values.

§

impl<T> MutablePrimitiveArray<T>
where T: NativeType,

Setters

pub fn set(&mut self, index: usize, value: Option<T>)

Sets position index to value. Note that if it is the first time a null appears in this array, this initializes the validity bitmap (O(N)).

§Panic

Panics iff index is larger than self.len().

pub unsafe fn set_unchecked(&mut self, index: usize, value: Option<T>)

Sets position index to value. Note that if it is the first time a null appears in this array, this initializes the validity bitmap (O(N)).

§Safety

Caller must ensure index < self.len()

pub fn set_validity(&mut self, validity: Option<MutableBitmap>)

Sets the validity.

§Panic

Panics iff the validity’s len is not equal to the existing values’ length.

pub fn set_values(&mut self, values: Vec<T>)

Sets values.

§Panic

Panics iff the values’ length is not equal to the existing validity’s len.

§

impl<T> MutablePrimitiveArray<T>
where T: NativeType,

pub fn from_slice<P>(slice: P) -> MutablePrimitiveArray<T>
where P: AsRef<[T]>,

Creates a MutablePrimitiveArray from a slice of values.

pub unsafe fn from_trusted_len_iter_unchecked<I, P>( iterator: I ) -> MutablePrimitiveArray<T>
where P: Borrow<T>, I: Iterator<Item = Option<P>>,

Creates a MutablePrimitiveArray from an iterator of trusted length.

§Safety

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

pub fn from_trusted_len_iter<I, P>(iterator: I) -> MutablePrimitiveArray<T>
where P: Borrow<T>, I: TrustedLen<Item = Option<P>>,

pub unsafe fn try_from_trusted_len_iter_unchecked<E, I, P>( iter: I ) -> Result<MutablePrimitiveArray<T>, E>
where P: Borrow<T>, I: IntoIterator<Item = Result<Option<P>, E>>,

Creates a MutablePrimitiveArray from an fallible iterator of trusted length.

§Safety

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

pub fn try_from_trusted_len_iter<E, I, P>( iterator: I ) -> Result<MutablePrimitiveArray<T>, E>
where P: Borrow<T>, I: TrustedLen<Item = Result<Option<P>, E>>,

Creates a MutablePrimitiveArray from an fallible iterator of trusted length.

pub fn from_trusted_len_values_iter<I>(iter: I) -> MutablePrimitiveArray<T>
where I: TrustedLen<Item = T>,

Creates a new MutablePrimitiveArray out an iterator over values

pub fn from_vec(values: Vec<T>) -> MutablePrimitiveArray<T>

Creates a (non-null) MutablePrimitiveArray from a vector of values. This does not have memcopy and is the fastest way to create a PrimitiveArray.

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

Creates a new MutablePrimitiveArray from an iterator over values

§Safety

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

Trait Implementations§

§

impl<T> Clone for MutablePrimitiveArray<T>
where T: Clone + NativeType,

§

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

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
§

impl<T> Debug for MutablePrimitiveArray<T>
where T: Debug + NativeType,

§

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

Formats the value using the given formatter. Read more
§

impl<T> Default for MutablePrimitiveArray<T>
where T: NativeType,

§

fn default() -> MutablePrimitiveArray<T>

Returns the “default value” for a type. Read more
§

impl<T> Extend<Option<T>> for MutablePrimitiveArray<T>
where T: NativeType,

§

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

Extends a collection with the contents of an iterator. Read more
source§

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)
Extends a collection with exactly one element.
source§

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. Read more
§

impl<T> From<DataType> for MutablePrimitiveArray<T>
where T: NativeType,

§

fn from(data_type: DataType) -> MutablePrimitiveArray<T>

Converts to this type from the input type.
§

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

§

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

Converts to this type from the input type.
§

impl<T, P> From<P> for MutablePrimitiveArray<T>
where T: NativeType, P: AsRef<[Option<T>]>,

§

fn from(slice: P) -> MutablePrimitiveArray<T>

Converts to this type from the input type.
§

impl<T, Ptr> FromIterator<Ptr> for MutablePrimitiveArray<T>
where T: NativeType, Ptr: Borrow<Option<T>>,

§

fn from_iter<I>(iter: I) -> MutablePrimitiveArray<T>
where I: IntoIterator<Item = Ptr>,

Creates a value from an iterator. Read more
§

impl<T> MutableArray for MutablePrimitiveArray<T>
where T: NativeType,

§

fn len(&self) -> usize

The length of the array.
§

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

The optional validity of the array.
§

fn as_box(&mut self) -> Box<dyn Array>

Convert itself to an (immutable) Array.
§

fn as_arc(&mut self) -> Arc<dyn Array>

Convert itself to an (immutable) atomically reference counted Array.
§

fn data_type(&self) -> &DataType

The DataType of the array.
§

fn as_any(&self) -> &(dyn Any + 'static)

Convert to Any, to enable dynamic casting.
§

fn as_mut_any(&mut self) -> &mut (dyn Any + 'static)

Convert to mutable Any, to enable dynamic casting.
§

fn push_null(&mut self)

Adds a new null element to the array.
§

fn reserve(&mut self, additional: usize)

Reserves additional slots to its capacity.
§

fn shrink_to_fit(&mut self)

Shrink the array to fit its length.
§

fn is_empty(&self) -> bool

Whether the array is empty.
§

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

Whether index is valid / set. Read more
§

impl<T> PartialEq for MutablePrimitiveArray<T>
where T: NativeType,

§

fn eq(&self, other: &MutablePrimitiveArray<T>) -> bool

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

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
§

impl<T> TryExtend<Option<T>> for MutablePrimitiveArray<T>
where T: NativeType,

§

fn try_extend<I>(&mut self, iter: I) -> Result<(), Error>
where I: IntoIterator<Item = Option<T>>,

This is infalible and is implemented for consistency with all other types

§

impl<T> TryExtendFromSelf for MutablePrimitiveArray<T>
where T: NativeType,

§

fn try_extend_from_self( &mut self, other: &MutablePrimitiveArray<T> ) -> Result<(), Error>

Tries to extend itself with elements from other, failing only on overflow.
§

impl<T> TryPush<Option<T>> for MutablePrimitiveArray<T>
where T: NativeType,

§

fn try_push(&mut self, item: Option<T>) -> Result<(), Error>

This is infalible and is implemented for consistency with all other types

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Az for T

source§

fn az<Dst>(self) -> Dst
where T: Cast<Dst>,

Casts the value.
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<Src, Dst> CastFrom<Src> for Dst
where Src: Cast<Dst>,

source§

fn cast_from(src: Src) -> Dst

Casts the value.
source§

impl<T> CheckedAs for T

source§

fn checked_as<Dst>(self) -> Option<Dst>
where T: CheckedCast<Dst>,

Casts the value.
source§

impl<Src, Dst> CheckedCastFrom<Src> for Dst
where Src: CheckedCast<Dst>,

source§

fn checked_cast_from(src: Src) -> Option<Dst>

Casts the value.
§

impl<T> Downcast<T> for T

§

fn downcast(&self) -> &T

§

impl<T> Downcast for T
where T: Any,

§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
§

impl<T> DowncastSync for T
where T: Any + Send + Sync,

§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Sync + Send>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
source§

impl<T> DynClone for T
where T: Clone,

source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> FromRef<T> for T
where T: Clone,

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<Src, Dst> LosslessTryInto<Dst> for Src
where Dst: LosslessTryFrom<Src>,

source§

fn lossless_try_into(self) -> Option<Dst>

Performs the conversion.
source§

impl<Src, Dst> LossyInto<Dst> for Src
where Dst: LossyFrom<Src>,

source§

fn lossy_into(self) -> Dst

Performs the conversion.
§

impl<T> NoneValue for T
where T: Default,

§

type NoneType = T

§

fn null_value() -> T

The none-equivalent value.
source§

impl<T> OverflowingAs for T

source§

fn overflowing_as<Dst>(self) -> (Dst, bool)
where T: OverflowingCast<Dst>,

Casts the value.
source§

impl<Src, Dst> OverflowingCastFrom<Src> for Dst
where Src: OverflowingCast<Dst>,

source§

fn overflowing_cast_from(src: Src) -> (Dst, bool)

Casts the value.
§

impl<T> Pointable for T

§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> SaturatingAs for T

source§

fn saturating_as<Dst>(self) -> Dst
where T: SaturatingCast<Dst>,

Casts the value.
source§

impl<Src, Dst> SaturatingCastFrom<Src> for Dst
where Src: SaturatingCast<Dst>,

source§

fn saturating_cast_from(src: Src) -> Dst

Casts the value.
§

impl<T> To for T
where T: ?Sized,

§

fn to<T>(self) -> T
where Self: Into<T>,

Converts to T by calling Into<T>::into.
§

fn try_to<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Tries to convert to T by calling TryInto<T>::try_into.
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> UnwrappedAs for T

source§

fn unwrapped_as<Dst>(self) -> Dst
where T: UnwrappedCast<Dst>,

Casts the value.
source§

impl<Src, Dst> UnwrappedCastFrom<Src> for Dst
where Src: UnwrappedCast<Dst>,

source§

fn unwrapped_cast_from(src: Src) -> Dst

Casts the value.
§

impl<T> Upcast<T> for T

§

fn upcast(&self) -> Option<&T>

§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
source§

impl<T> WrappingAs for T

source§

fn wrapping_as<Dst>(self) -> Dst
where T: WrappingCast<Dst>,

Casts the value.
source§

impl<Src, Dst> WrappingCastFrom<Src> for Dst
where Src: WrappingCast<Dst>,

source§

fn wrapping_cast_from(src: Src) -> Dst

Casts the value.
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

§

impl<T> Ungil for T
where T: Send,

§

impl<T> WasmNotSend for T
where T: Send,

§

impl<T> WasmNotSendSync for T

§

impl<T> WasmNotSync for T
where T: Sync,