Skip to content

Commit 81dfffa

Browse files
committed
fix typos
1 parent ae18d24 commit 81dfffa

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/query/storages/common/blocks/src/parquet_rs.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -61,12 +61,12 @@ pub fn blocks_to_parquet_with_stats(
6161
) -> Result<FileMetaData> {
6262
assert!(!blocks.is_empty());
6363
let builder = parquet_writer_properties_builder(compression, enable_dictionary, metadata);
64-
let builder = if let Some(cols_stats) = column_stats {
64+
let builder = if let Some(stats) = column_stats {
6565
let num_rows = blocks[0].num_rows();
6666
adjust_writer_properties_by_col_stats(
6767
builder,
6868
enable_dictionary,
69-
cols_stats,
69+
stats,
7070
num_rows,
7171
table_schema,
7272
)
@@ -124,7 +124,7 @@ pub fn adjust_writer_properties_by_col_stats(
124124

125125
let mut builder = builder.set_dictionary_enabled(false);
126126

127-
let colum_names: HashMap<_, _> = table_schema
127+
let column_names: HashMap<_, _> = table_schema
128128
.fields
129129
.iter()
130130
.map(|f| (f.column_id, f.name.as_str()))
@@ -133,8 +133,8 @@ pub fn adjust_writer_properties_by_col_stats(
133133
if let Some(ndv) = stats.distinct_of_values {
134134
if (ndv as f64 / num_rows as f64) < 0.1 {
135135
// DOC safe to unwrap
136-
let col_name = colum_names.get(col_id).unwrap();
137-
builder = builder.set_column_dictionary_enabled(ColumnPath::from(*col_name), true);
136+
let name = column_names.get(col_id).unwrap();
137+
builder = builder.set_column_dictionary_enabled(ColumnPath::from(*name), true);
138138
}
139139
}
140140
}

0 commit comments

Comments
 (0)