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

fix: update read_buffer tests

pull/24376/head
Andrew Lamb 2021-07-13 15:37:40 -04:00
parent 4800b36949
commit 97c727a2c2
5 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
read_buffer/src/chunk.rs
View File

@ -659,9 +659,9 @@ mod test {
"# HELP read_buffer_column_bytes The number of bytes used by all columns in the Read Buffer",
"# TYPE read_buffer_column_bytes gauge",
r#"read_buffer_column_bytes{db="mydb",encoding="BT_U32-FIXED",log_data_type="i64"} 72"#,
r#"read_buffer_column_bytes{db="mydb",encoding="FBT_U8-FIXEDN",log_data_type="f64"} 688"#,
r#"read_buffer_column_bytes{db="mydb",encoding="FBT_U8-FIXEDN",log_data_type="f64"} 800"#,
r#"read_buffer_column_bytes{db="mydb",encoding="FIXED",log_data_type="f64"} 96"#,
r#"read_buffer_column_bytes{db="mydb",encoding="FIXEDN",log_data_type="bool"} 768"#,
r#"read_buffer_column_bytes{db="mydb",encoding="FIXEDN",log_data_type="bool"} 672"#,
r#"read_buffer_column_bytes{db="mydb",encoding="RLE",log_data_type="string"} 500"#,
"# HELP read_buffer_column_raw_bytes The number of bytes used by all columns if they were uncompressed in the Read Buffer",
"# TYPE read_buffer_column_raw_bytes gauge",

2
read_buffer/src/column/encoding/bool.rs
View File

@ -360,7 +360,7 @@ mod test {
#[test]
fn size() {
let v = Bool::from(vec![None, None, Some(true), Some(false)].as_slice());
assert_eq!(v.size(), 464);
assert_eq!(v.size(), 400);
}
#[test]

2
read_buffer/src/column/encoding/scalar/fixed_null.rs
View File

@ -478,7 +478,7 @@ mod test {
#[test]
fn size() {
let (v, _) = new_encoding(vec![None, None, Some(100), Some(2222)]);
assert_eq!(v.size(), 352);
assert_eq!(v.size(), 408);
}
#[test]

22
read_buffer/src/column/integer.rs
View File

@ -971,13 +971,13 @@ mod test {
// Input data containing NULL will be stored in an Arrow array encoding
let cases = vec![
(vec![None, Some(0_i64)], 344_usize), // u8 Arrow array
(vec![None, Some(-120_i64)], 344), // i8
(vec![None, Some(399_i64)], 344), // u16
(vec![None, Some(-399_i64)], 344), // i16
(vec![None, Some(u32::MAX as i64)], 344), // u32
(vec![None, Some(i32::MIN as i64)], 344), // i32
(vec![None, Some(u32::MAX as i64 + 1)], 344), //u64
(vec![None, Some(0_i64)], 400_usize), // u8 Arrow array
(vec![None, Some(-120_i64)], 400), // i8
(vec![None, Some(399_i64)], 400), // u16
(vec![None, Some(-399_i64)], 400), // i16
(vec![None, Some(u32::MAX as i64)], 400), // u32
(vec![None, Some(i32::MIN as i64)], 400), // i32
(vec![None, Some(u32::MAX as i64 + 1)], 400), //u64
];
for (case, name) in cases.iter().cloned() {
@ -1163,10 +1163,10 @@ mod test {
// Input data containing NULL will be stored in an Arrow array encoding
let cases = vec![
(vec![None, Some(0_u64)], 344_usize),
(vec![None, Some(399_u64)], 344),
(vec![None, Some(u32::MAX as u64)], 344),
(vec![None, Some(u64::MAX)], 344),
(vec![None, Some(0_u64)], 400_usize),
(vec![None, Some(399_u64)], 400),
(vec![None, Some(u32::MAX as u64)], 400),
(vec![None, Some(u64::MAX)], 400),
];
for (case, size) in cases.iter().cloned() {

2
src/influxdb_ioxd/rpc/flight.rs
View File

@ -17,7 +17,7 @@ use arrow::{
use arrow_flight::{
flight_service_server::{FlightService as Flight, FlightServiceServer as FlightServer},
Action, ActionType, Criteria, Empty, FlightData, FlightDescriptor, FlightInfo,
HandshakeRequest, HandshakeResponse, PutResult, SchemaResult, Ticket,
HandshakeRequest, HandshakeResponse, PutResult, SchemaAsIpc, SchemaResult, Ticket,
};
use data_types::{DatabaseName, DatabaseNameError};
use server::{ConnectionManager, Server};