Struct StreamExecutor 

pub struct StreamExecutor<T>
where
    T: Clone + Send + Sync + 'static,
{ /* private fields */ }

Stream executor for processing events through a pipeline

The executor handles:

• Event ingestion from sources
• Watermark generation and propagation
• Window assignment and lifecycle management
• Trigger evaluation
• Aggregation computation
• Result emission to sinks

Example

use processor::pipeline::{StreamPipelineBuilder, StreamExecutor};
use processor::config::WindowConfig;

let pipeline = StreamPipelineBuilder::new()
    .with_name("example")
    .with_tumbling_window(60_000)
    .build()?;

let mut executor = pipeline.create_executor::<f64>();

// Ingest events
executor.ingest(42.0).await?;
executor.ingest(100.0).await?;

// Process and emit results
// executor.run().await?;

Implementations

impl<T> StreamExecutor<T>

where T: Clone + Send + Sync + 'static + Serialize + for<'de> Deserialize<'de>,

pub fn new(pipeline: StreamPipeline) -> Self

Create a new stream executor

pub async fn ingest(&self, event: T) -> Result<()>

Ingest an event into the pipeline

Example

let mut executor = pipeline.create_executor::<f64>();
executor.ingest(42.5).await?;

pub async fn ingest_batch(&self, events: Vec<T>) -> Result<()>

Ingest a batch of events

pub async fn next_output(&self) -> Option<ProcessorEvent<T>>

Get the next output event

pub async fn stats(&self) -> ExecutorStats

Get current statistics

pub async fn current_watermark(&self) -> Watermark

Get current watermark

pub fn is_running(&self) -> bool

Check if the executor is running

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

where T: EventTimeExtractor<T> + KeyExtractor<T>,

Run the executor (process events continuously)

This will process events from the input channel until stopped.

Example

let executor = pipeline.create_executor::<f64>();

// Run in a background task
tokio::spawn(async move {
    // executor.run().await.unwrap();
});

pub fn stop(&self)

Stop the executor

pub fn active_window_count(&self) -> usize

Get the number of active windows

pub fn clear_windows(&self)

Clear all window states

Trait Implementations

impl<T> Drop for StreamExecutor<T>

where T: Clone + Send + Sync,

fn drop(&mut self)

Executes the destructor for this type.