Struct StreamingExecutor 

pub struct StreamingExecutor { /* private fields */ }

Streaming executor for processing data in chunks

Implementations

impl StreamingExecutor

pub fn new(chunk_size: usize, max_buffer_size: usize) -> Self

Create a new streaming executor

pub fn create_chunks(&self, data: Vec<f32>, node_id: &str) -> Vec<StreamChunk>

Split input data into chunks

pub fn execute_chunk( &self, _graph: &ComputationGraph, chunk: StreamChunk, ) -> Result<StreamChunk, GraphError>

Execute graph on a stream chunk

pub fn process_stream( &self, graph: &ComputationGraph, chunks: Vec<StreamChunk>, ) -> Result<Vec<StreamChunk>, GraphError>

Process a stream of chunks through the graph

pub fn buffer_size(&self) -> usize

Get the current buffer size

pub fn clear_buffer(&self)

Clear the buffer

pub fn chunk_size(&self) -> usize

Get chunk size

pub fn max_buffer_size(&self) -> usize

Get max buffer size