Struct datafusion::execution::memory_pool::GreedyMemoryPool
source · pub struct GreedyMemoryPool { /* private fields */ }
Expand description
A MemoryPool
that implements a greedy first-come first-serve limit.
This pool works well for queries that do not need to spill or have
a single spillable operator. See GreedyMemoryPool
if there are
multiple spillable operators that all will spill.
Implementations§
source§impl GreedyMemoryPool
impl GreedyMemoryPool
sourcepub fn new(pool_size: usize) -> GreedyMemoryPool
pub fn new(pool_size: usize) -> GreedyMemoryPool
Allocate up to limit
bytes
Trait Implementations§
source§impl Debug for GreedyMemoryPool
impl Debug for GreedyMemoryPool
source§impl MemoryPool for GreedyMemoryPool
impl MemoryPool for GreedyMemoryPool
source§fn grow(&self, _reservation: &MemoryReservation, additional: usize)
fn grow(&self, _reservation: &MemoryReservation, additional: usize)
source§fn shrink(&self, _reservation: &MemoryReservation, shrink: usize)
fn shrink(&self, _reservation: &MemoryReservation, shrink: usize)
Infallibly shrink the provided
reservation
by shrink
bytessource§fn try_grow(
&self,
reservation: &MemoryReservation,
additional: usize
) -> Result<(), DataFusionError>
fn try_grow( &self, reservation: &MemoryReservation, additional: usize ) -> Result<(), DataFusionError>
source§fn register(&self, _consumer: &MemoryConsumer)
fn register(&self, _consumer: &MemoryConsumer)
Registers a new
MemoryConsumer
Read moresource§fn unregister(&self, _consumer: &MemoryConsumer)
fn unregister(&self, _consumer: &MemoryConsumer)
Auto Trait Implementations§
impl RefUnwindSafe for GreedyMemoryPool
impl Send for GreedyMemoryPool
impl Sync for GreedyMemoryPool
impl Unpin for GreedyMemoryPool
impl UnwindSafe for GreedyMemoryPool
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more