Struct PolarsObjectStore

pub struct PolarsObjectStore { /* private fields */ }

Available on crate feature cloud only.

Polars wrapper around [ObjectStore] functionality. This struct is cheaply cloneable.

Implementations

impl PolarsObjectStore

pub async fn to_dyn_object_store(&self) -> Arc<dyn ObjectStore>

Gets the underlying [ObjectStore] implementation.

pub async fn rebuild_inner( &self, from_version: &Arc<dyn ObjectStore>, ) -> PolarsResult<Arc<dyn ObjectStore>>

pub async fn try_exec_rebuild_on_err<Fn, Fut, O>( &self, func: Fn, ) -> PolarsResult<O>

where Fn: FnMut(&Arc<dyn ObjectStore>) -> Fut, Fut: Future<Output = PolarsResult<O>>,

impl PolarsObjectStore

pub async fn get_range( &self, path: &Path, range: Range<usize>, ) -> PolarsResult<Bytes>

pub async fn get_ranges_sort<K: TryFrom<usize, Error = impl Debug> + Hash + Eq, T: From<Bytes>>( &self, path: &Path, ranges: &mut [Range<usize>], ) -> PolarsResult<PlHashMap<K, T>>

Fetch byte ranges into a HashMap keyed by the range start. This will mutably sort the ranges slice for coalescing.

Panics

Panics if the same range start is used by more than 1 range.

pub async fn download(&self, path: &Path, file: &mut File) -> PolarsResult<()>

pub async fn head(&self, path: &Path) -> PolarsResult<ObjectMeta>

Fetch the metadata of the parquet file, do not memoize it.

Trait Implementations

impl Clone for PolarsObjectStore

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PolarsObjectStore

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

Formats the value using the given formatter.