Struct CatalogConnectConfig 

pub struct CatalogConnectConfig {
    pub uri: String,
    pub storage_options: Option<AHashMap<String, String>>,
    pub batch_size: Option<usize>,
    pub compression: Option<CatalogCompression>,
    pub max_row_group_size: Option<usize>,
    pub params: Option<Params>,
}

Minimal connection-config supplied to CatalogFactory.

Fields

uri: String

Resolved URI for the catalog backend (e.g. file:///tmp/cat, s3://bucket/cat).

storage_options: Option<AHashMap<String, String>>

Optional storage-backend options (credentials, region, …) passed to object_store.

batch_size: Option<usize>

The number of rows per batch the catalog reads and writes.

compression: Option<CatalogCompression>

The compression codec of written data files.

max_row_group_size: Option<usize>

The maximum number of rows per written row group.

params: Option<Params>

Backend-specific catalog parameters, which a factory validates with validate_catalog_params.

Implementations

impl CatalogConnectConfig

pub fn new( uri: impl Into<String>, storage_options: Option<AHashMap<String, String>>, ) -> Self

Creates a new CatalogConnectConfig.

pub fn from_path_and_protocol( path: &str, fs_protocol: Option<&str>, storage_options: Option<AHashMap<String, String>>, ) -> Self

Builds a CatalogConnectConfig from path + optional fs_protocol.

A file protocol with a Windows drive path becomes file:///C:/.... A path that already contains :// is left unchanged.

Trait Implementations

impl Clone for CatalogConnectConfig

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 CatalogConnectConfig

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

Formats the value using the given formatter.