Struct spark_connect_core::streaming::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 awaitTermination( self, timeout_ms: Option<i64> ) -> Result<bool, SparkError>

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

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

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

pub async fn stop(self) -> Result<bool, 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.