Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: remove unused max_row_group_size 

The Parquet writer references an unused max_row_group_size property in
the parquet file metadata.
pull/24376/head
Dom Dwyer 2022-05-18 16:45:15 +01:00
parent 4bd899369e
commit 7a8e6d1a38
1 changed files with 1 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
parquet_file/src/storage.rs
View File

@ -87,22 +87,11 @@ pub type Result<T, E = Error> = std::result::Result<T, E>;
#[derive(Debug, Clone)]
pub struct Storage {
object_store: Arc<DynObjectStore>,
// If `Some`, restricts the size of the row groups created in the parquet file
max_row_group_size: Option<usize>,
}
impl Storage {
pub fn new(object_store: Arc<DynObjectStore>) -> Self {
Self {
object_store,
max_row_group_size: None,
}
}
/// Specify the maximum sized row group to make
pub fn set_max_row_group_size(&mut self, max_row_group_size: usize) {
self.max_row_group_size = Some(max_row_group_size);
Self { object_store }
}
fn writer_props(&self, metadata_bytes: &[u8]) -> WriterProperties {
@ -113,12 +102,6 @@ impl Storage {
}]))
.set_compression(Compression::ZSTD);
let builder = if let Some(max_row_group_size) = self.max_row_group_size.as_ref() {
builder.set_max_row_group_size(*max_row_group_size)
} else {
builder
};
builder.build()
}