Enum Trigger 

pub enum Trigger {
    ProcessingTime(String),
    Once,
    AvailableNow,
    Continuous(String),
}

Trigger for streaming queries.

Variants

ProcessingTime(String)

Process every interval milliseconds or duration string (e.g., “10 seconds”).

Once

Process only once.

AvailableNow

Process as soon as available data arrives.

Continuous(String)

Continuous processing with checkpoint interval.

Trait Implementations

impl Clone for Trigger

fn clone(&self) -> Trigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Trigger

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

Formats the value using the given formatter.