Skip to main content

DataFrameWriterExt

spark_connect::ext

Trait DataFrameWriterExt 

Source 
pub trait DataFrameWriterExt {
    // Required methods
    fn save_async(
        self,
        path: Option<&str>,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn save_as_table_async(
        self,
        table_name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn insert_into_async(
        self,
        table_name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn csv_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn json_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn orc_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn parquet_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn text_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn xml_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
}
Expand description

Async actions on a DataFrameWriter.

Required Methods§

Source

fn save_async( self, path: Option<&str>, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::save.

Source

fn save_as_table_async( self, table_name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::save_as_table.

Source

fn insert_into_async( self, table_name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::insert_into.

Source

fn csv_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::csv.

Source

fn json_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::json.

Source

fn orc_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::orc.

Source

fn parquet_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::parquet.

Source

fn text_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::text.

Source

fn xml_async( self, path: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrameWriter::xml.

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§