Struct datafusion::execution::disk_manager::DiskManager

pub struct DiskManager { /* private fields */ }

Manages files generated during query execution, e.g. spill files generated while processing dataset larger than available memory.

Implementations

impl DiskManager

pub fn try_new(config: DiskManagerConfig) -> Result<Arc<Self>>

Create a DiskManager given the configuration

pub fn create_tmp_file(&self, request_description: &str) -> Result<NamedTempFile>

Return a temporary file from a randomized choice in the configured locations

If the file can not be created for some reason, returns an error message referencing the request description

Trait Implementations

impl Debug for DiskManager

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

Formats the value using the given formatter.