Struct StreamingQuery

pub struct StreamingQuery { /* private fields */ }

Represents the active streaming created from a start on the writer

This object is used to control and monitor the active stream

Implementations

impl StreamingQuery

pub fn new( spark_session: Box<SparkSession>, write_stream: WriteStreamOperationStartResult, ) -> Self

pub fn id(&self) -> String

pub fn run_id(&self) -> String

pub fn name(&self) -> Option<String>

pub async fn await_termination( &self, timeout_ms: Option<i64>, ) -> Result<bool, SparkError>

pub async fn last_progress(&self) -> Result<Value, SparkError>

pub async fn recent_progress(&self) -> Result<Value, SparkError>

pub async fn is_active(&self) -> Result<bool, SparkError>

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

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

pub async fn explain(&self, extended: Option<bool>) -> Result<(), SparkError>

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

pub async fn status(&self) -> Result<StatusResult, SparkError>

Trait Implementations

impl Clone for StreamingQuery

fn clone(&self) -> StreamingQuery

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingQuery

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

Formats the value using the given formatter.