Skip to main content

StreamingQueryExt

spark_connect::ext

Trait StreamingQueryExt 

Source 
pub trait StreamingQueryExt {
    // Required methods
    fn is_active_async(
        &self,
    ) -> impl Future<Output = Result<bool>> + Send + 'static;
    fn status_async(
        &self,
    ) -> impl Future<Output = Result<StreamingQueryStatus>> + Send + 'static;
    fn stop_async(&self) -> impl Future<Output = Result<()>> + Send + 'static;
    fn await_termination_async(
        &self,
        timeout_sec: Option<f64>,
    ) -> impl Future<Output = Result<Option<bool>>> + Send + 'static;
    fn exception_async(
        &self,
    ) -> impl Future<Output = Result<Option<StreamingQueryException>>> + Send + 'static;
    fn last_progress_async(
        &self,
    ) -> impl Future<Output = Result<Option<String>>> + Send + 'static;
    fn recent_progress_async(
        &self,
    ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static;
    fn process_all_available_async(
        &self,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn explain_async(
        &self,
        extended: bool,
    ) -> impl Future<Output = Result<String>> + Send + 'static;
}
Expand description

Async actions on a StreamingQuery.

Required Methods§

Source

fn is_active_async(&self) -> impl Future<Output = Result<bool>> + Send + 'static

Async StreamingQuery::is_active.

Source

fn status_async( &self, ) -> impl Future<Output = Result<StreamingQueryStatus>> + Send + 'static

Async StreamingQuery::status.

Source

fn stop_async(&self) -> impl Future<Output = Result<()>> + Send + 'static

Async StreamingQuery::stop.

Source

fn await_termination_async( &self, timeout_sec: Option<f64>, ) -> impl Future<Output = Result<Option<bool>>> + Send + 'static

Async StreamingQuery::await_termination.

Source

fn exception_async( &self, ) -> impl Future<Output = Result<Option<StreamingQueryException>>> + Send + 'static

Async StreamingQuery::exception.

Source

fn last_progress_async( &self, ) -> impl Future<Output = Result<Option<String>>> + Send + 'static

Async StreamingQuery::last_progress.

Source

fn recent_progress_async( &self, ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static

Async StreamingQuery::recent_progress.

Source

fn process_all_available_async( &self, ) -> impl Future<Output = Result<()>> + Send + 'static

Async StreamingQuery::process_all_available.

Source

fn explain_async( &self, extended: bool, ) -> impl Future<Output = Result<String>> + Send + 'static

Async StreamingQuery::explain.

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§