From 7a31b2a8ea2b256d38382d283fa6e5ddc87f9ec7 Mon Sep 17 00:00:00 2001 From: evenyag Date: Fri, 21 Nov 2025 15:39:05 +0800 Subject: [PATCH] refactor: rename elapsed to fetch_elapsed Signed-off-by: evenyag --- src/index/src/bloom_filter/reader.rs | 14 +++++++------- src/index/src/inverted_index/format/reader.rs | 4 ++-- src/index/src/inverted_index/format/reader/blob.rs | 4 ++-- src/mito2/src/cache/index/bloom_filter_index.rs | 4 ++-- src/mito2/src/cache/index/inverted_index.rs | 4 ++-- 5 files changed, 15 insertions(+), 15 deletions(-) diff --git a/src/index/src/bloom_filter/reader.rs b/src/index/src/bloom_filter/reader.rs index 9b139c1260..56e83eab15 100644 --- a/src/index/src/bloom_filter/reader.rs +++ b/src/index/src/bloom_filter/reader.rs @@ -42,8 +42,8 @@ pub struct BloomFilterReadMetrics { pub total_bytes: u64, /// Total number of ranges to read. pub total_ranges: usize, - /// Elapsed time of the read_vec operation. - pub elapsed: Duration, + /// Elapsed time to fetch data. + pub fetch_elapsed: Duration, } /// Safely converts bytes to Vec using bytemuck for optimal performance. @@ -117,7 +117,7 @@ pub trait BloomFilterReader: Sync { m.total_ranges += ranges.len(); m.total_bytes += ranges.iter().map(|r| r.end - r.start).sum::(); if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } @@ -200,7 +200,7 @@ impl BloomFilterReader for BloomFilterReaderImpl { m.total_ranges += 1; m.total_bytes += size as u64; if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } @@ -219,7 +219,7 @@ impl BloomFilterReader for BloomFilterReaderImpl { m.total_ranges += ranges.len(); m.total_bytes += ranges.iter().map(|r| r.end - r.start).sum::(); if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } @@ -295,7 +295,7 @@ impl BloomFilterMetaReader { m.total_ranges += 2; // suffix read + meta read m.total_bytes += (self.file_size - meta_start) + length; if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } @@ -305,7 +305,7 @@ impl BloomFilterMetaReader { m.total_ranges += 1; // suffix read only m.total_bytes += self.file_size.min(self.prefetch_size); if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } diff --git a/src/index/src/inverted_index/format/reader.rs b/src/index/src/inverted_index/format/reader.rs index d8b492a8e5..fd435fab4e 100644 --- a/src/index/src/inverted_index/format/reader.rs +++ b/src/index/src/inverted_index/format/reader.rs @@ -37,8 +37,8 @@ pub struct InvertedIndexReadMetrics { pub total_bytes: u64, /// Total number of ranges to read. pub total_ranges: usize, - /// Elapsed time of the read_vec operation. - pub elapsed: Duration, + /// Elapsed time to fetch data. + pub fetch_elapsed: Duration, } /// InvertedIndexReader defines an asynchronous reader of inverted index data diff --git a/src/index/src/inverted_index/format/reader/blob.rs b/src/index/src/inverted_index/format/reader/blob.rs index 1acdb74d8c..fd10ba9b3f 100644 --- a/src/index/src/inverted_index/format/reader/blob.rs +++ b/src/index/src/inverted_index/format/reader/blob.rs @@ -71,7 +71,7 @@ impl InvertedIndexReader for InvertedIndexBlobReader { if let Some(m) = metrics { m.total_bytes += size as u64; m.total_ranges += 1; - m.elapsed += start.unwrap().elapsed(); + m.fetch_elapsed += start.unwrap().elapsed(); } Ok(buf.into()) @@ -89,7 +89,7 @@ impl InvertedIndexReader for InvertedIndexBlobReader { if let Some(m) = metrics { m.total_bytes += ranges.iter().map(|r| r.end - r.start).sum::(); m.total_ranges += ranges.len(); - m.elapsed += start.unwrap().elapsed(); + m.fetch_elapsed += start.unwrap().elapsed(); } Ok(result) diff --git a/src/mito2/src/cache/index/bloom_filter_index.rs b/src/mito2/src/cache/index/bloom_filter_index.rs index 93ae9af6c1..4daf516567 100644 --- a/src/mito2/src/cache/index/bloom_filter_index.rs +++ b/src/mito2/src/cache/index/bloom_filter_index.rs @@ -139,7 +139,7 @@ impl BloomFilterReader for CachedBloomFilterIndexBl m.total_ranges += 1; m.total_bytes += size as u64; if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } @@ -174,7 +174,7 @@ impl BloomFilterReader for CachedBloomFilterIndexBl m.total_ranges += ranges.len(); m.total_bytes += ranges.iter().map(|r| r.end - r.start).sum::(); if let Some(start) = start { - m.elapsed += start.elapsed(); + m.fetch_elapsed += start.elapsed(); } } diff --git a/src/mito2/src/cache/index/inverted_index.rs b/src/mito2/src/cache/index/inverted_index.rs index c85aa2548a..e7c3019dfd 100644 --- a/src/mito2/src/cache/index/inverted_index.rs +++ b/src/mito2/src/cache/index/inverted_index.rs @@ -107,7 +107,7 @@ impl InvertedIndexReader for CachedInvertedIndexBlobRead if let Some(m) = metrics { m.total_bytes += size as u64; m.total_ranges += 1; - m.elapsed += start.unwrap().elapsed(); + m.fetch_elapsed += start.unwrap().elapsed(); } Ok(result) @@ -140,7 +140,7 @@ impl InvertedIndexReader for CachedInvertedIndexBlobRead if let Some(m) = metrics { m.total_bytes += ranges.iter().map(|r| r.end - r.start).sum::(); m.total_ranges += ranges.len(); - m.elapsed += start.unwrap().elapsed(); + m.fetch_elapsed += start.unwrap().elapsed(); } Ok(pages)