common.libs.pyiceberg
ensure_pyiceberg_local_path
def ensure_pyiceberg_local_path(location: str) -> str
Converts local absolute paths into file urls.
get_catalog
def get_catalog(
client: FilesystemClient,
table_name: str,
namespace_name: Optional[str] = None,
schema: Optional[pa.Schema] = None,
partition_columns: Optional[List[str]] = None) -> MetastoreCatalog
Returns single-table, ephemeral, in-memory Iceberg catalog.