Skip to content

Commit 6dff8e3

Browse files
authored
chore: fix typo in ColumnCacheKeyBuilder (#16838)
1 parent 2ccede3 commit 6dff8e3

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/query/storages/fuse/src/io/read/block/block_reader_merge_io_async.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ impl BlockReader {
6161
if let Some(column_meta) = columns_meta.get(column_id) {
6262
let (offset, len) = column_meta.offset_length();
6363

64-
let column_cache_key = column_cache_key_builder.cache_cache(column_id, column_meta);
64+
let column_cache_key = column_cache_key_builder.cache_key(column_id, column_meta);
6565

6666
// first, check in memory table data cache
6767
// column_array_cache
@@ -106,7 +106,7 @@ impl BlockReader {
106106

107107
// Safe to unwrap here, since this column has been fetched, its meta must be present.
108108
let column_meta = columns_meta.get(column_id).unwrap();
109-
let column_cache_key = column_cache_key_builder.cache_cache(column_id, column_meta);
109+
let column_cache_key = column_cache_key_builder.cache_key(column_id, column_meta);
110110

111111
let chunk_data = merge_io_result
112112
.owner_memory
@@ -133,7 +133,7 @@ impl<'a> ColumnCacheKeyBuilder<'a> {
133133
fn new(block_path: &'a str) -> Self {
134134
Self { block_path }
135135
}
136-
fn cache_cache(&self, column_id: &ColumnId, column_meta: &ColumnMeta) -> TableDataCacheKey {
136+
fn cache_key(&self, column_id: &ColumnId, column_meta: &ColumnMeta) -> TableDataCacheKey {
137137
let (offset, len) = column_meta.offset_length();
138138
TableDataCacheKey::new(self.block_path, *column_id, offset, len)
139139
}

0 commit comments

Comments
 (0)