Struct StreamExecutor 

pub struct StreamExecutor { /* private fields */ }

Processes a stream of chunks through a sequence of fitted filters.

Respects each filter’s StreamMode:

• FixedState: each chunk processed independently, cacheable per chunk
• Evolving: state mutates with each chunk, periodic checkpoints
• Barrier: accumulates all chunks, processes as batch

Implementations

impl StreamExecutor

pub fn new(filters: Vec<FittedFilter>) -> Self

pub fn with_cache(self, cache: Arc<dyn CacheStore>) -> Self

pub fn process_chunk(&mut self, chunk: Value) -> Result<Option<Value>>

Process a single chunk through the pipeline.

Returns the output chunk, or None if a Barrier filter is still accumulating.

pub fn flush(&mut self) -> Result<Option<Value>>

Flush barrier filters and process remaining data as batch.

Call this after the stream ends to materialize barrier outputs.

pub fn process_all(&mut self, chunks: Vec<Value>) -> Result<Vec<Value>>

Process multiple chunks and collect outputs.

pub fn chunks_processed(&self) -> usize

Number of chunks processed so far.