Enum Command 

pub enum Command {
    Status(bool),
    LastProgress(bool),
    RecentProgress(bool),
    Stop(bool),
    ProcessAllAvailable(bool),
    Explain(ExplainCommand),
    Exception(bool),
    AwaitTermination(AwaitTerminationCommand),
}

See documentation for the corresponding API method in StreamingQuery.

Variants

Status(bool)

status() API.

LastProgress(bool)

lastProgress() API.

RecentProgress(bool)

recentProgress() API.

Stop(bool)

stop() API. Stops the query.

ProcessAllAvailable(bool)

processAllAvailable() API. Waits till all the available data is processed

Explain(ExplainCommand)

explain() API. Returns logical and physical plans.

Exception(bool)

exception() API. Returns the exception in the query if any.

AwaitTermination(AwaitTerminationCommand)

awaitTermination() API. Waits for the termination of the query.

Implementations

impl Command

pub fn encode(&self, buf: &mut impl BufMut)

Encodes the message to a buffer.

pub fn merge( field: &mut Option<Command>, tag: u32, wire_type: WireType, buf: &mut impl Buf, ctx: DecodeContext, ) -> Result<(), DecodeError>

Decodes an instance of the message from a buffer, and merges it into self.

pub fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

Trait Implementations

impl Clone for Command

fn clone(&self) -> Command

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Command

impl Debug for Command

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

Formats the value using the given formatter.

impl Eq for Command

impl Hash for Command

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Command

fn eq(&self, other: &Command) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Command