Struct Executor 

pub struct Executor { /* private fields */ }

A tiny, single-pipeline executor. Wires: Source -> Operators -> Sink. Drives watermarks and event-time timers.

Implementations

impl Executor

pub fn new() -> Self

Create a new empty executor.

pub fn source<S: Source + 'static>(&mut self, s: S) -> &mut Self

Set the pipeline source.

pub fn operator<O: Operator + 'static>(&mut self, o: O) -> &mut Self

Append an operator to the pipeline.

pub fn sink<K: Sink + 'static>(&mut self, s: K) -> &mut Self

Set the pipeline sink.

pub async fn run(&mut self) -> Result<()>

Run the pipeline to completion. The loop exits when the source finishes and the internal channel closes. Watermarks are propagated and due timers fired.