Skip to main content

ParquetCatalogSource

nautilus_persistence::backend::migration

Trait ParquetCatalogSource 

Source 
pub trait ParquetCatalogSource: Sync {
    // Required methods
    fn object_store(&self) -> Arc<dyn ObjectStore> ⓘ;
    fn base_path(&self) -> &str;
    fn original_uri(&self) -> &str;

    // Provided method
    fn to_object_path_parsed(&self, path: &str) -> Result<ObjectPath> { ... }
}
Expand description

Object-store source used to plan and read a legacy Parquet migration.

Required Methods§

Source

fn object_store(&self) -> Arc<dyn ObjectStore> ⓘ

Returns the object store containing the source catalog.

Source

fn base_path(&self) -> &str

Returns the catalog path within the object store.

Source

fn original_uri(&self) -> &str

Returns the URI identifying the source catalog.

Provided Methods§

Source

fn to_object_path_parsed(&self, path: &str) -> Result<ObjectPath>

Resolves a plan-relative path within the source catalog.

§Errors

Returns an error if the combined object-store path is invalid.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§