Trait DataStreamWriterExt 

pub trait DataStreamWriterExt {
    // Required methods
    fn start_async(
        self,
        path: &str,
    ) -> impl Future<Output = Result<StreamingQuery>> + Send + 'static;
    fn to_table_async(
        self,
        table_name: &str,
    ) -> impl Future<Output = Result<StreamingQuery>> + Send + 'static;
}

Async actions on a DataStreamWriter.

Required Methods

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

Async DataStreamWriter::start.

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

Async DataStreamWriter::to_table.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors

impl DataStreamWriterExt for DataStreamWriter