Struct QueryHandle 

pub struct QueryHandle { /* private fields */ }

Handle to a running streaming query.

Implementations

impl QueryHandle

pub fn schema(&self) -> &SchemaRef

Get the output schema.

pub fn sql(&self) -> &str

Get the query SQL text.

pub fn id(&self) -> u64

Get the query ID.

pub fn is_active(&self) -> bool

Check if the query is still active.

pub fn subscribe<T: FromBatch>( &mut self, ) -> Result<TypedSubscription<T>, DbError>

Subscribe to typed results.

The type T must implement from_batch() and from_batch_all() methods, which are generated by #[derive(FromRecordBatch)].

Errors

Returns DbError::InvalidOperation if the subscription was already consumed.

pub fn cancel(&mut self)

Cancel this query.

Trait Implementations

impl Debug for QueryHandle

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

Formats the value using the given formatter.