Struct datafusion::execution::runtime_env::RuntimeEnv

pub struct RuntimeEnv {
    pub memory_manager: Arc<MemoryManager>,
    pub disk_manager: Arc<DiskManager>,
    pub object_store_registry: Arc<ObjectStoreRegistry>,
}

Execution runtime environment.

Fields

memory_manager: Arc<MemoryManager>

Runtime memory management

disk_manager: Arc<DiskManager>

Manage temporary files during query execution

object_store_registry: Arc<ObjectStoreRegistry>

Object Store Registry

Implementations

impl RuntimeEnv

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

Create env based on configuration

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

pub fn register_object_store(
    &self,
    scheme: impl AsRef<str>,
    host: impl AsRef<str>,
    object_store: Arc<dyn ObjectStore>
) -> Option<Arc<dyn ObjectStore>>

Registers a object store with scheme using a custom ObjectStore so that an external file system or object storage system could be used against this context.

Returns the ObjectStore previously registered for this scheme, if any

pub fn object_store(&self, url: impl AsRef<Url>) -> Result<Arc<dyn ObjectStore>>

Retrieves a ObjectStore instance for a url

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.