/// Add a new parquet file to the catalog.
///
/// If a file with the same path already exists an error will be returned.
Add a new parquet file to the catalog.
If a file with the same path already exists an error will be returned.
Add a new parquet file to the catalog . If a file with the same path already exists an error will be returned .
pub fn add_parquet(
        &mut self,
        path: &DirsAndFileName,
        metadata: &ParquetMetaData,
    ) -> Result<()> {
        self.transaction
            .as_mut()
            .expect("transaction handle w/o transaction?!")
            .handle_action_and_record(
                proto::transaction::action::Action::AddParquet(proto::AddParquet {
                    path: Some(unparse_dirs_and_filename(path)),
                    metadata: parquet_metadata_to_thrift(metadata)
                        .context(MetadataEncodingFailed)?,
                }),
                &self.catalog.object_store,
                self.catalog.server_id,
                &self.catalog.db_name,
            )
    }
pub fn add_parquet ( & mut self , path : & DirsAndFileName , metadata : & ParquetMetaData , ) -> Result < ( ) > { self . transaction . as_mut ( ) . expect ( " " ) . handle_action_and_record ( proto :: transaction :: action :: Action :: AddParquet ( proto :: AddParquet { path : Some ( unparse_dirs_and_filename ( path ) ) , metadata : parquet_metadata_to_thrift ( metadata ) . context ( MetadataEncodingFailed ) ? , } ) , & self . catalog . object_store , self . catalog . server_id , & self . catalog . db_name , ) }
Add a new parquet file to the catalog.
Add a new parquet file to the catalog .
&mut self
path
&DirsAndFileName
metadata
&ParquetMetaData