MemoryAccumulator

Struct MemoryAccumulator 

Source
pub struct MemoryAccumulator { /* private fields */ }
Expand description

Counts memory used by buffers of Arrow arrays and RecordBatches.

This is meant to capture how much memory is being used by the Arrow data structures as they are. It does not represent the memory used if the data were to be serialized and then deserialized. In particular:

  • This does not double count memory used by buffers shared by multiple arrays or batches. Round-tripped data may use more memory because of this.
  • This counts the total size of the buffers, even if the array is a slice. Round-tripped data may use less memory because of this.

Implementations§

Source§

impl MemoryAccumulator

Source

pub fn record_array(&mut self, array: &dyn Array)

Source

pub fn record_batch(&mut self, batch: &RecordBatch)

Source

pub fn total(&self) -> usize

Trait Implementations§

Source§

impl Default for MemoryAccumulator

Source§

fn default() -> MemoryAccumulator

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

Auto Trait Implementations§

Blanket Implementations§

§

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

§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
§

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

§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
§

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

§

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

Mutably borrows from an owned value. Read more
§

impl<T> From<T> for T

§

fn from(t: T) -> T

Returns the argument unchanged.

§

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

§

fn into(self) -> U

Calls U::from(self).

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

§

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

§

type Error = Infallible

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

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

Performs the conversion.
§

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

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

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