diff --git a/rust/blockstore/src/types/writer.rs b/rust/blockstore/src/types/writer.rs index f956e089a74..e251b745454 100644 --- a/rust/blockstore/src/types/writer.rs +++ b/rust/blockstore/src/types/writer.rs @@ -80,7 +80,7 @@ impl BlockfileWriter { } } - pub async fn get_clone< + pub async fn get_owned< K: Key + Into + ArrowWriteableKey, V: Value + Writeable + ArrowWriteableValue, >( @@ -91,7 +91,7 @@ impl BlockfileWriter { match self { BlockfileWriter::MemoryBlockfileWriter(_) => todo!(), BlockfileWriter::ArrowUnorderedBlockfileWriter(writer) => { - writer.get_clone::(prefix, key).await + writer.get_owned::(prefix, key).await } BlockfileWriter::ArrowOrderedBlockfileWriter(_) => todo!(), } diff --git a/rust/index/src/spann/types.rs b/rust/index/src/spann/types.rs index fcb2d34d982..c122eb40b28 100644 --- a/rust/index/src/spann/types.rs +++ b/rust/index/src/spann/types.rs @@ -377,7 +377,7 @@ impl SpannIndexWriter { // TODO(Sanket): Check if head is deleted, can happen if another concurrent thread // deletes it. let current_pl = write_guard - .get_clone::>("", head_id) + .get_owned::>("", head_id) .await .map_err(|_| SpannIndexWriterConstructionError::PostingListSearchError)? .ok_or(SpannIndexWriterConstructionError::PostingListSearchError)?; diff --git a/rust/worker/src/segment/spann_segment.rs b/rust/worker/src/segment/spann_segment.rs index dd6a787ab34..56593a75853 100644 --- a/rust/worker/src/segment/spann_segment.rs +++ b/rust/worker/src/segment/spann_segment.rs @@ -464,7 +464,7 @@ mod test { // Test PL. let read_guard = spann_writer.index.posting_list_writer.lock().await; let res = read_guard - .get_clone::>("", 1) + .get_owned::>("", 1) .await .expect("Expected posting list to be present") .expect("Expected posting list to be present");