Skip to content

Commit c45b732

Browse files
committed
[ENH]: Add spann metrics
1 parent cba0b8d commit c45b732

File tree

9 files changed

+342
-21
lines changed

9 files changed

+342
-21
lines changed

rust/blockstore/src/arrow/flusher.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,4 +75,8 @@ impl ArrowBlockfileFlusher {
7575
pub(crate) fn count(&self) -> u64 {
7676
self.count
7777
}
78+
79+
pub(crate) fn num_blocks(&self) -> usize {
80+
self.blocks.len()
81+
}
7882
}

rust/blockstore/src/types/flusher.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,4 +38,11 @@ impl BlockfileFlusher {
3838
BlockfileFlusher::ArrowBlockfileFlusher(flusher) => flusher.count(),
3939
}
4040
}
41+
42+
pub fn num_blocks(&self) -> usize {
43+
match self {
44+
BlockfileFlusher::MemoryBlockfileFlusher(_) => unimplemented!(),
45+
BlockfileFlusher::ArrowBlockfileFlusher(flusher) => flusher.num_blocks(),
46+
}
47+
}
4148
}

0 commit comments

Comments
 (0)