Expand description
Streaming evaluation over large datasets.
StreamingEvaluator wraps an ExpressionEvaluator with reusable
buffers, so processing a stream of input rows uses constant memory
regardless of stream length. This mirrors the semantics of Symbolica’s
streaming.rs: rows flow through the evaluator one at a time and
results are consumed by a sink callback.
Structs§
- Streaming
Evaluator - Streaming evaluator with reusable internal buffers.