Struct StreamProcessor 

pub struct StreamProcessor { /* private fields */ }

Stream processor for handling streaming execution

Implementations

impl StreamProcessor

pub fn new(config: StreamingConfig) -> Self

pub fn split_batch<T: Clone>( &self, batch: &BatchResult<T>, ) -> Vec<(ChunkMetadata, Vec<T>)>

Split batch result into chunks based on configuration

pub fn merge_results<T>(results: Vec<StreamResult<T>>) -> BatchResult<T>

Merge stream results back into a single batch

pub fn adaptive_chunk_size(&self, results: &[StreamResult<impl Clone>]) -> usize

Calculate adaptive chunk size based on performance metrics

pub fn config(&self) -> &StreamingConfig

Trait Implementations

impl Default for StreamProcessor

fn default() -> Self

Returns the “default value” for a type.