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

refactor: remove time field from Table meta

pull/24376/head
Edd Robinson 2021-04-26 10:09:49 +01:00 committed by kodiakhq[bot]
parent 2a6eed97c6
commit 15bde2f8fa
1 changed files with 0 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
read_buffer/src/table.rs
View File

@ -509,13 +509,6 @@ pub struct MetaData {
// The names of the columns for this table in the order they appear.
column_names: Vec<String>,
// The total time range of this table spanning all of the row groups within
// the table.
//
// This can be used to skip the table entirely if the time range for a query
// falls outside of this range.
time_range: Option<(i64, i64)>,
}
impl MetaData {
@ -525,7 +518,6 @@ impl MetaData {
rows: rg.rows() as u64,
columns: rg.metadata().columns.clone(),
column_names: rg.metadata().column_names.clone(),
time_range: Some(rg.metadata().time_range),
}
}
@ -573,16 +565,6 @@ impl MetaData {
if column_range_max > &curr_range.1 {
curr_range.1 = column_range_max.clone();
}
match this.time_range {
Some(time_range) => {
this.time_range = Some((
time_range.0.min(other.time_range.0),
time_range.1.max(other.time_range.1),
));
}
None => panic!("cannot call `update` on empty Metadata"),
}
}
this
@ -972,7 +954,6 @@ mod test {
assert_eq!(meta.rows, 3);
let meta_size = meta.size;
assert!(meta_size > 0);
assert_eq!(meta.time_range, Some((100, 300)));
assert_eq!(
meta.columns.get("region").unwrap().range,
(
@ -993,7 +974,6 @@ mod test {
meta = MetaData::update_with(meta, &rg);
assert_eq!(meta.rows, 5);
assert!(meta.size > meta_size);
assert_eq!(meta.time_range, Some((10, 400)));
assert_eq!(
meta.columns.get("region").unwrap().range,
(
@ -1020,7 +1000,6 @@ mod test {
table.add_row_group(rg);
assert_eq!(table.rows(), 8);
assert_eq!(table.meta().time_range, Some((0, 5)));
assert_eq!(
table.meta().columns.get("time").unwrap().range,
(
@ -1032,7 +1011,6 @@ mod test {
// remove the first row group
table.drop_row_group(0).unwrap();
assert_eq!(table.rows(), 5);
assert_eq!(table.meta().time_range, Some((1, 5)));
assert_eq!(
table.meta().columns.get("time").unwrap().range,
(