Skip to content

Commit b779e32

Browse files
committed
prefetch record segment
1 parent 01d5917 commit b779e32

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

rust/worker/src/execution/orchestration/spann_knn.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,16 @@ impl Orchestrator for SpannKnnOrchestrator {
197197
);
198198
tasks.push(prefetch_task);
199199

200+
let prefetch_record_segment_task = wrap(
201+
Box::new(PrefetchSegmentOperator::new()),
202+
PrefetchSegmentInput::new(
203+
self.knn_filter_output.record_segment.clone(),
204+
self.spann_provider.blockfile_provider.clone(),
205+
),
206+
ctx.receiver(),
207+
);
208+
tasks.push(prefetch_record_segment_task);
209+
200210
tasks
201211
}
202212

0 commit comments

Comments
 (0)