Struct datafusion_execution::disk_manager::DiskManager
source · pub struct DiskManager { /* private fields */ }
Expand description
Manages files generated during query execution, e.g. spill files generated while processing dataset larger than available memory.
Implementations§
source§impl DiskManager
impl DiskManager
sourcepub fn try_new(config: DiskManagerConfig) -> Result<Arc<Self>>
pub fn try_new(config: DiskManagerConfig) -> Result<Arc<Self>>
Create a DiskManager given the configuration
sourcepub fn tmp_files_enabled(&self) -> bool
pub fn tmp_files_enabled(&self) -> bool
Return true if this disk manager supports creating temporary
files. If this returns false, any call to create_tmp_file
will error.
sourcepub fn create_tmp_file(
&self,
request_description: &str
) -> Result<NamedTempFile>
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§
Auto Trait Implementations§
impl !RefUnwindSafe for DiskManager
impl Send for DiskManager
impl Sync for DiskManager
impl Unpin for DiskManager
impl UnwindSafe for DiskManager
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