Struct ResolvedParquetSource 

pub struct ResolvedParquetSource {
    pub original_location: String,
    pub input: ResolvedParquetInput,
    pub storage_domain: Option<String>,
    pub content_identity: Option<String>,
    pub cache_status: LakehouseCacheStatus,
    pub lakehouse_cache_read_mode: LakehouseCacheReadMode,
    pub lakehouse_cache_root: Option<String>,
    pub lakehouse_cache_path: Option<String>,
    pub lakehouse_cache_max_bytes: Option<u64>,
    pub lakehouse_cache_fill_mode: LakehouseCacheFillMode,
    /* private fields */
}

Resolved Parquet reader contract carried into native source execution.

Fields

original_location: String

Frontend-supplied file location before read-strategy resolution.

input: ResolvedParquetInput

The only data-plane input supplied to cuDF.

storage_domain: Option<String>

Credential-free storage domain used for cache scoping, when known.

content_identity: Option<String>

Credential-free content identity used for cache scoping, when known.

cache_status: LakehouseCacheStatus

Local byte-cache status for this source.

lakehouse_cache_read_mode: LakehouseCacheReadMode

Foreground cache-read behavior for this source.

lakehouse_cache_root: Option<String>

Lakehouse byte-cache root used by cache maintenance, when configured.

lakehouse_cache_path: Option<String>

Complete-object cache path used for hit reads or background fills.

lakehouse_cache_max_bytes: Option<u64>

Best-effort retained byte target for the lakehouse byte-cache root.

lakehouse_cache_fill_mode: LakehouseCacheFillMode

Cache-fill mode for complete-object lakehouse cache maintenance.

Implementations

impl ResolvedParquetSource

pub fn local_kvikio(location: impl Into<String>) -> Self

Builds a local path-based read contract.

pub fn local_cache_kvikio( original_location: impl Into<String>, reader_location: impl Into<String>, credential_mode: CredentialMode, cache_status: LakehouseCacheStatus, ) -> Self

Builds a read contract for a local byte-cache entry, with the given cache status.

pub fn remote_kvikio( original_location: impl Into<String>, credential_mode: CredentialMode, ) -> Self

Builds a remote path-based read contract where cuDF/libcudf owns the object-store read. Host-memory Parquet payloads are not representable.

pub fn with_cache_status(self, cache_status: LakehouseCacheStatus) -> Self

Replaces the local byte-cache status after strategy fallback.

pub fn with_lakehouse_cache_read_mode( self, read_mode: LakehouseCacheReadMode, ) -> Self

Selects foreground complete-object lakehouse cache read behavior.

pub fn with_storage_domain(self, storage_domain: impl Into<String>) -> Self

Attaches a credential-free storage-domain identity for cache scoping.

pub fn with_content_identity(self, content_identity: impl Into<String>) -> Self

Attaches a credential-free content identity for cache scoping.

pub fn with_storage_profile_id(self, profile_id: impl Into<String>) -> Self

Attaches the execution-time source storage profile id.

pub fn with_optional_storage_profile_id( self, profile_id: Option<String>, ) -> Self

Attaches an execution-time source storage profile id when present.

pub fn with_lakehouse_cache_config( self, cache_root: impl Into<String>, max_retained_bytes: Option<u64>, ) -> Self

Attaches lakehouse byte-cache maintenance settings.

pub fn with_lakehouse_cache_path(self, cache_path: impl Into<String>) -> Self

Attaches a complete-object lakehouse cache path.

pub fn with_lakehouse_cache_fill_mode( self, fill_mode: LakehouseCacheFillMode, ) -> Self

Selects complete-object lakehouse cache fill behavior.

pub fn reader_location(&self) -> &str

Path or URI passed to cuDF.

pub fn credential_mode(&self) -> CredentialMode

Credential scope for the active remote read or local-cache maintenance.

pub fn storage_profile_id(&self) -> Option<&str>

Storage profile for the active remote read or local-cache maintenance.

pub fn read_strategy(&self) -> ParquetReadStrategy

Report-facing strategy derived from the tagged input and cache facts.

Trait Implementations

impl Clone for ResolvedParquetSource

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResolvedParquetSource

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

Formats the value using the given formatter.

impl Eq for ResolvedParquetSource

impl Hash for ResolvedParquetSource

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ResolvedParquetSource

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ResolvedParquetSource