From e7daf1226fde2a19e6e4b8bb7f65336cd72d7984 Mon Sep 17 00:00:00 2001 From: "Lei, HUANG" Date: Mon, 13 Mar 2023 20:01:44 +0800 Subject: [PATCH] feat: tune parquet parameters --- src/storage/src/sst/parquet.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/storage/src/sst/parquet.rs b/src/storage/src/sst/parquet.rs index 10a66a9f20..7c888de3e2 100644 --- a/src/storage/src/sst/parquet.rs +++ b/src/storage/src/sst/parquet.rs @@ -96,6 +96,10 @@ impl<'a> ParquetWriter<'a> { .set_column_encoding(ColumnPath::new(vec![ts_col_name]), Encoding::DELTA_BINARY_PACKED) .set_column_dictionary_enabled(ColumnPath::new(vec!["__sequence".to_string()]), false) .set_column_encoding(ColumnPath::new(vec!["__sequence".to_string()]), Encoding::DELTA_BINARY_PACKED) + .set_column_dictionary_enabled(ColumnPath::new(vec![ts_col_name.clone()]), false) + .set_column_encoding(ColumnPath::new(vec![ts_col_name]), Encoding::DELTA_BINARY_PACKED) + .set_column_dictionary_enabled(ColumnPath::new(vec!["__sequence".to_string()]), false) + .set_column_encoding(ColumnPath::new(vec!["__sequence".to_string()]), Encoding::DELTA_BINARY_PACKED) .set_max_row_group_size(self.max_row_group_size) .set_key_value_metadata(extra_meta.map(|map| { map.iter()