Skip to content

Commit bb36737

Browse files
authored
chore(query): add more snapshot/segment serde tests (#16273)
* meta-test * update * chore(query): add tests to cover snapshot and segment serde
1 parent bfb919d commit bb36737

File tree

3 files changed

+17
-2
lines changed

3 files changed

+17
-2
lines changed
Binary file not shown.
Binary file not shown.

src/query/service/tests/it/storages/fuse/meta/snapshot.rs

Lines changed: 17 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,21 @@ fn test_snapshot_v1_to_v4() {
112112

113113
#[test]
114114
fn test_snapshot_reader() {
115-
let meta = include_bytes!("legacy_tpch_v4.mpk");
116-
TableSnapshot::from_slice(meta).unwrap();
115+
for data in [
116+
include_bytes!("legacy_tpch_v4.mpk").as_slice(),
117+
include_bytes!("c_sn_v4.mpk").as_slice(),
118+
] {
119+
let sn = TableSnapshot::from_slice(data).unwrap();
120+
assert!(sn.schema.num_fields() > 0);
121+
assert!(!sn.segments.is_empty());
122+
assert_eq!(sn.summary.col_stats.len(), sn.schema.num_fields());
123+
}
124+
}
125+
126+
#[test]
127+
fn test_seg_reader() {
128+
let meta = include_bytes!("c_seg_v4.mpk");
129+
let seg = databend_storages_common_table_meta::meta::SegmentInfo::from_slice(meta).unwrap();
130+
assert!(!seg.summary.col_stats.is_empty());
131+
assert!(!seg.blocks.is_empty());
117132
}

0 commit comments

Comments
 (0)