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

refactor: further address Carol's comment

pull/24376/head
Nga Tran 2021-05-07 17:40:40 -04:00
parent 971500681f
commit f2c19ec080
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
parquet_file/src/storage_testing.rs
View File

@ -47,7 +47,7 @@ mod tests {
// Now let read it back
//
let (_read_table, parquet_data) = load_parquet_from_store(&chunk, Arc::clone(&store)).await;
let parquet_metadata = read_parquet_metadata_from_file(parquet_data).unwrap();
let parquet_metadata = read_parquet_metadata_from_file(parquet_data.clone()).unwrap();
//
// 1. Check metadata at file level: Everything is correct
let schema_actual = read_schema_from_parquet_metadata(&parquet_metadata).unwrap();
@ -65,8 +65,6 @@ mod tests {
assert_eq!(timestamp_range_actual, Some(time_range));
// 3. Check data
// Read the parquet data from object store
let (_read_table, parquet_data) = load_parquet_from_store(&chunk, Arc::clone(&store)).await;
// Note that the read_data_from_parquet_data function fixes the row-group/batches' level metadata bug in arrow
let actual_record_batches =
read_data_from_parquet_data(Arc::clone(&schema.as_arrow()), parquet_data);