From ec3954df665650b2ec967b1de8a401f0695ff791 Mon Sep 17 00:00:00 2001 From: Sanket Kedia Date: Sun, 10 Nov 2024 22:25:01 -0800 Subject: [PATCH] Build errors --- rust/blockstore/src/types/writer.rs | 5 +++-- rust/index/src/spann/types.rs | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/rust/blockstore/src/types/writer.rs b/rust/blockstore/src/types/writer.rs index 6862c17f20eb..f956e089a747 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 3b57cda44534..0f8fa31c9efc 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(|_| {