Enum DynByteSource 

pub enum DynByteSource {
    Buffer(BufferByteSource),
    File(FileByteSource),
    Cloud(ObjectStoreByteSource),
}

Available on crate feature async only.

Dynamic dispatch to async functions.

Variants

Buffer(BufferByteSource)

File(FileByteSource)

Cloud(ObjectStoreByteSource)

Available on crate feature cloud only.

Implementations

impl DynByteSource

pub fn variant_name(&self) -> &str

pub fn with_fetch_config(&self, config: FetchConfig) -> Option<Self>

A clone of this object store source with a different fetch configuration. The clone shares the underlying store, and this source keeps its configuration. Returns None for non-object store sources.

pub fn is_cloud(&self) -> bool

pub fn chunk_size(&self) -> Option<usize>

pub fn concurrency_strategy(&self) -> Option<ConcurrencyStrategy>

Trait Implementations

impl ByteSource for DynByteSource

async fn get_size(&self) -> PolarsResult<usize>

async fn get_suffix(&self, n: usize) -> PolarsResult<(Buffer<u8>, usize)>

Fetch the last n bytes and the total size of the source, in a single request. Returns fewer than n bytes if the source is smaller than n.

async fn get_prefix(&self, n: usize) -> PolarsResult<(Buffer<u8>, usize)>

Fetch the first n bytes and the total size of the source, in a single request where supported. Returns fewer than n bytes if the source is smaller than n.

async fn get_range(&self, range: Range<usize>) -> PolarsResult<Buffer<u8>>

Panics

async fn get_ranges( &self, ranges: &mut [Range<usize>], ) -> PolarsResult<PlHashMap<usize, Buffer<u8>>>

Note: This will mutably sort ranges for coalescing.

impl Default for DynByteSource

fn default() -> Self

Returns the “default value” for a type.

impl From<Buffer<u8>> for DynByteSource

fn from(value: Buffer<u8>) -> Self

Converts to this type from the input type.

impl From<BufferByteSource> for DynByteSource

fn from(value: BufferByteSource) -> Self

Converts to this type from the input type.

impl From<FileByteSource> for DynByteSource

fn from(value: FileByteSource) -> Self

Converts to this type from the input type.

impl From<ObjectStoreByteSource> for DynByteSource

Available on crate feature cloud only.

fn from(value: ObjectStoreByteSource) -> Self

Converts to this type from the input type.