diff --git a/rust/blockstore/src/types/writer.rs b/rust/blockstore/src/types/writer.rs index 6862c17f20e..f956e089a74 100644 --- a/rust/blockstore/src/types/writer.rs +++ b/rust/blockstore/src/types/writer.rs @@ -87,12 +87,13 @@ impl BlockfileWriter { &self, prefix: &str, key: K, - ) -> Result, Box> { + ) -> Result, Box> { match self { BlockfileWriter::MemoryBlockfileWriter(_) => todo!(), - BlockfileWriter::ArrowBlockfileWriter(writer) => { + BlockfileWriter::ArrowUnorderedBlockfileWriter(writer) => { writer.get_clone::(prefix, key).await } + BlockfileWriter::ArrowOrderedBlockfileWriter(_) => todo!(), } } diff --git a/rust/index/src/spann/types.rs b/rust/index/src/spann/types.rs index 3b57cda4453..0f8fa31c9ef 100644 --- a/rust/index/src/spann/types.rs +++ b/rust/index/src/spann/types.rs @@ -251,7 +251,7 @@ impl SpannIndexWriter { let max_head_id = match max_head_id_bf_id { Some(max_head_id_bf_id) => { let reader = blockfile_provider - .open::<&str, u32>(max_head_id_bf_id) + .read::<&str, u32>(max_head_id_bf_id) .await; match reader { Ok(reader) => reader.get("", MAX_HEAD_OFFSET_ID).await.map_err(|_| {