Struct Catalog

pub struct Catalog { /* private fields */ }

Implementations

impl Catalog

pub fn new(spark_session: SparkSession) -> Self

pub async fn current_catalog(self) -> Result<String, SparkError>

Returns the current default catalog in this session

pub async fn set_current_catalog( self, catalog_name: &str, ) -> Result<(), SparkError>

pub async fn list_catalogs( self, pattern: Option<&str>, ) -> Result<RecordBatch, SparkError>

Returns a list of catalogs in this session

pub async fn current_database(self) -> Result<String, SparkError>

Returns the current default database in this session

pub async fn set_current_database(self, db_name: &str) -> Result<(), SparkError>

pub async fn list_databases( self, pattern: Option<&str>, ) -> Result<RecordBatch, SparkError>

Returns a list of databases in this session

pub async fn get_database( self, db_name: &str, ) -> Result<RecordBatch, SparkError>

pub async fn database_exists(self, db_name: &str) -> Result<bool, SparkError>

pub async fn list_tables( self, pattern: Option<&str>, db_name: Option<&str>, ) -> Result<RecordBatch, SparkError>

Returns a list of tables/views in the specific database

pub async fn get_table( self, table_name: &str, ) -> Result<RecordBatch, SparkError>

pub async fn list_functions( self, db_name: Option<&str>, pattern: Option<&str>, ) -> Result<RecordBatch, SparkError>

pub async fn function_exists( self, function_name: &str, db_name: Option<&str>, ) -> Result<bool, SparkError>

pub async fn get_function( self, function_name: &str, ) -> Result<RecordBatch, SparkError>

pub async fn list_columns( self, table_name: &str, db_name: Option<&str>, ) -> Result<RecordBatch, SparkError>

Returns a list of columns for the given tables/views in the specific database

pub async fn table_exists( self, table_name: &str, db_name: Option<&str>, ) -> Result<bool, SparkError>

pub async fn drop_temp_view(self, view_name: &str) -> Result<bool, SparkError>

pub async fn drop_global_temp_view( self, view_name: &str, ) -> Result<bool, SparkError>

pub async fn is_cached(self, table_name: &str) -> Result<bool, SparkError>

pub async fn cache_table( self, table_name: &str, storage_level: Option<StorageLevel>, ) -> Result<(), SparkError>

pub async fn uncache_table(self, table_name: &str) -> Result<(), SparkError>

pub async fn clear_cache(self) -> Result<(), SparkError>

pub async fn refresh_table(self, table_name: &str) -> Result<(), SparkError>

pub async fn recover_partitions( self, table_name: &str, ) -> Result<(), SparkError>

pub async fn refresh_by_path(self, path: &str) -> Result<(), SparkError>

Trait Implementations

impl Clone for Catalog

fn clone(&self) -> Catalog

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Catalog

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

Formats the value using the given formatter.