Struct Batched 

pub struct Batched<'a> {
    pub data_ref: &'a DataRef,
    pub batch_size: usize,
}

Batched forward: read rows from a DataStore in fixed-size batches. Keeps memory bounded — only one batch is materialized at a time.

Fields

data_ref: &'a DataRef

batch_size: usize

Trait Implementations

impl ForwardStrategy for Batched<'_>

fn forward( &self, graph: &Graph, library: &FilterLibrary, cache: &dyn CacheStore, event_bus: &Arc<EventBus>, data_store: Option<&Arc<dyn DataStore>>, _x: &Value, ) -> Result<Value>

Execute a forward pass, returning the final output.