Struct datafusion::execution::runtime_env::RuntimeEnv

pub struct RuntimeEnv {
    pub batch_size: usize,
    pub memory_manager: Arc<MemoryManager>,
    pub disk_manager: Arc<DiskManager>,
}

Execution runtime environment. This structure is passed to the physical plans when they are run.

Fields

batch_size: usize

Default batch size while creating new batches

memory_manager: Arc<MemoryManager>

Runtime memory management

disk_manager: Arc<DiskManager>

Manage temporary files during query execution

Implementations

impl RuntimeEnv

pub fn new(config: RuntimeConfig) -> Result<Self>

Create env based on configuration

pub fn batch_size(&self) -> usize

Get execution batch size based on config

pub fn register_requester(&self, id: &MemoryConsumerId)

Register the consumer to get it tracked

pub fn drop_consumer(&self, id: &MemoryConsumerId, mem_used: usize)

Drop the consumer from get tracked, reclaim memory

pub fn grow_tracker_usage(&self, delta: usize)

Grow tracker memory of delta

pub fn shrink_tracker_usage(&self, delta: usize)

Shrink tracker memory of delta

Trait Implementations

impl Clone for RuntimeEnv

fn clone(&self) -> RuntimeEnv

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeEnv

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

Formats the value using the given formatter.

impl Default for RuntimeEnv

fn default() -> Self

Returns the “default value” for a type.