@@ -133,19 +133,19 @@ pub(crate) async fn load_vector_index_files<'a>(
133
133
. map ( |( _, meta) | meta)
134
134
. collect ( ) ;
135
135
136
- // 4. read column datas , first try to read from cache,
136
+ // 4. read column data , first try to read from cache,
137
137
// if not exists, fetch from object storage
138
138
let mut ranges = Vec :: new ( ) ;
139
139
let mut names_map = HashMap :: new ( ) ;
140
- let mut column_datas = HashMap :: new ( ) ;
140
+ let mut column_data = HashMap :: new ( ) ;
141
141
let vector_index_file_cache = CacheManager :: instance ( ) . get_vector_index_file_cache ( ) ;
142
142
for ( i, ( name, col_meta) ) in column_indices
143
143
. iter ( )
144
144
. zip ( projected_column_metas. into_iter ( ) )
145
145
{
146
146
let cache_key = cache_key_of_column ( location, name) ;
147
147
if let Some ( cache_file) = vector_index_file_cache. get_sized ( & cache_key, col_meta. len ) {
148
- column_datas . insert ( * i, cache_file) ;
148
+ column_data . insert ( * i, cache_file) ;
149
149
continue ;
150
150
}
151
151
@@ -172,15 +172,15 @@ pub(crate) async fn load_vector_index_files<'a>(
172
172
173
173
// add index file to cache
174
174
vector_index_file_cache. insert ( cache_key, file. clone ( ) ) ;
175
- column_datas . insert ( * i as usize , Arc :: new ( file) ) ;
175
+ column_data . insert ( * i as usize , Arc :: new ( file) ) ;
176
176
}
177
177
}
178
178
179
- // 5. deserialize raw data to vector index datas
179
+ // 5. deserialize raw data to vector index data
180
180
let mut builder =
181
181
RowGroupImplBuilder :: new ( 1 , & vector_index_schema_desc, TableCompression :: Zstd . into ( ) ) ;
182
182
183
- for ( i, column_data) in column_datas {
183
+ for ( i, column_data) in column_data {
184
184
builder. add_column_chunk ( i, Bytes :: copy_from_slice ( & column_data. data ) ) ;
185
185
}
186
186
let row_group = Box :: new ( builder. build ( ) ) ;
0 commit comments