Module executor 

Stream executor for running stream processing pipelines

This module provides the execution engine for stream processing pipelines, handling event ingestion, watermark propagation, window management, and result emission.

Structs

ExecutorStats

Statistics for the stream executor

StreamExecutor

Stream executor for processing events through a pipeline