Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
PSeitz committed May 10, 2024
1 parent ab15ca1 commit afb99b2
Showing 1 changed file with 10 additions and 8 deletions.
18 changes: 10 additions & 8 deletions quickwit/quickwit-search/src/root.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1407,7 +1407,7 @@ pub fn jobs_to_leaf_request(
search_request_for_leaf.start_offset = 0;
search_request_for_leaf.max_hits += request.start_offset;

let mut multi_leaf_request = LeafSearchRequest {
let mut leaf_search_request = LeafSearchRequest {
search_request: Some(search_request_for_leaf),
leaf_requests: Vec::new(),
doc_mappers: Vec::new(),
Expand All @@ -1426,26 +1426,28 @@ pub fn jobs_to_leaf_request(
let doc_mapper_ord = *added_doc_mappers
.entry(&search_index_meta.doc_mapper_str)
.or_insert_with(|| {
let ord = multi_leaf_request.doc_mappers.len();
multi_leaf_request
let ord = leaf_search_request.doc_mappers.len();
leaf_search_request
.doc_mappers
.push(search_index_meta.doc_mapper_str.to_string());
ord as u32
});
let index_uri_ord = multi_leaf_request.index_uris.len() as u32;
multi_leaf_request
let index_uri_ord = leaf_search_request.index_uris.len() as u32;
leaf_search_request
.index_uris
.push(search_index_meta.index_uri.to_string());

let leaf_search_request = LeafRequestRef {
let leaf_search_request_ref = LeafRequestRef {
split_offsets: job_group.into_iter().map(|job| job.offsets).collect(),
doc_mapper_ord,
index_uri_ord,
};
multi_leaf_request.leaf_requests.push(leaf_search_request);
leaf_search_request
.leaf_requests
.push(leaf_search_request_ref);
Ok(())
})?;
Ok(multi_leaf_request)
Ok(leaf_search_request)
}

/// Builds a list of [`FetchDocsRequest`], one per index, from a list of [`FetchDocsJob`].
Expand Down

0 comments on commit afb99b2

Please sign in to comment.