Struct StreamingEvaluator 

pub struct StreamingEvaluator<'a, T: EvaluationDomain> { /* private fields */ }

Streaming evaluator with reusable internal buffers.

Created from a borrowed ExpressionEvaluator; all scratch memory (parameter staging, evaluation stack, result buffer) is allocated once up front and reused for every row.

Example

let eval: ExpressionEvaluator<f64> = ExpressionEvaluator::compile(atom)?;
let mut stream = StreamingEvaluator::new(&eval);
let rows = (0..1_000_000).map(|i| [i as f64]);
let n = stream.for_each(rows, |results| {
    // consume results (same buffer, valid only within the callback)
})?;
assert_eq!(n, 1_000_000);

Implementations

impl<T: EvaluationDomain + PowfExtension> StreamingEvaluator<'_, T>

pub fn new(evaluator: &ExpressionEvaluator<T>) -> StreamingEvaluator<'_, T>

Create a streaming evaluator, pre-allocating all buffers.

pub fn for_each<I, S, F>(&mut self, rows: I, sink: F) -> Result<usize>

where I: IntoIterator<Item = S>, S: AsRef<[T]>, F: FnMut(&[T]),

Process a stream of input rows, invoking sink with the result slice for each row.

Each row must contain exactly param_count values; the slice passed to sink contains result_count values and is only valid for the duration of the callback. Returns the number of rows processed.

Memory usage is constant: no allocation grows with the number of rows.

Errors

Returns crate::EvaluationError if a row has the wrong arity or an arithmetic error occurs during evaluation.

pub fn evaluate_chunk<S: AsRef<[T]>>( &mut self, rows: &[S], ) -> Result<Vec<Vec<T>>>

Process a chunk of rows and collect all results.

Convenience method for bounded batches; prefer for_each for unbounded streams. Returns one result vector per row.

Errors

Returns crate::EvaluationError if a row has the wrong arity or an arithmetic error occurs during evaluation.