Struct ArrowMemoryPool 

pub struct ArrowMemoryPool { /* private fields */ }

Available on crate feature arrow_buffer_pool only.

An adapter that implements Arrow’s arrow_buffer::MemoryPool trait by wrapping a DataFusion MemoryPool.

This allows DataFusion’s memory management system to be used with Arrow’s memory allocation APIs. Each reservation made through this pool will be tracked using the provided MemoryConsumer, enabling DataFusion to monitor and limit memory usage across Arrow operations.

This is useful when you want Arrow operations (such as array builders or compute kernels) to participate in DataFusion’s memory management and respect the same memory limits as DataFusion operators.

Implementations

impl ArrowMemoryPool

pub fn new(inner: Arc<dyn MemoryPool>, consumer: MemoryConsumer) -> Self

Creates a new ArrowMemoryPool that wraps the given DataFusion MemoryPool and tracks allocations under the specified MemoryConsumer.

Trait Implementations

impl Debug for ArrowMemoryPool

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

Formats the value using the given formatter.

impl MemoryPool for ArrowMemoryPool

fn reserve(&self, size: usize) -> Box<dyn MemoryReservation>

Reserves memory from the pool. Infallible.

fn available(&self) -> isize

Returns the current available memory in the pool.

fn used(&self) -> usize

Returns the current used memory from the pool.

fn capacity(&self) -> usize

Returns the maximum memory that can be reserved from the pool.