Skip to main content

collect_from

Function collect_from 

Source
pub fn collect_from<P, F>(pull: P, degree_of: F, cap: usize) -> FuzzyResultSet
where P: FnMut(&mut BindingRow) -> bool, F: Fn(&BindingRow) -> f64,
Expand description

Pull rows from a live engine operator and annotate them. pull is the engine’s row-at-a-time step (typically a closure wrapping PhysicalOperator::next(ctx, row)): it fills the row and returns true while more solutions remain. This is the genuine integration shape — no copy of the executor, no SparqlQueryContext leak into this library. cap bounds the pull (fail-safe against an unbounded operator).