Skip to content

Commit 5d52ef7

Browse files
committed
Fix test logic
1 parent 2890262 commit 5d52ef7

File tree

1 file changed

+7
-6
lines changed
  • parquet/src/column/writer

1 file changed

+7
-6
lines changed

parquet/src/column/writer/mod.rs

+7-6
Original file line numberDiff line numberDiff line change
@@ -3396,7 +3396,7 @@ mod tests {
33963396
}
33973397
";
33983398
let schema = Arc::new(parse_message_type(message_type).unwrap());
3399-
let data = vec![ByteArray::from(vec![128u8; 32]); 7];
3399+
let data = vec![ByteArray::from(b"parquet".to_vec()); 7];
34003400
let def_levels = [1, 1, 1, 1, 0, 1, 0, 1, 0, 1];
34013401

34023402
let file: File = tempfile::tempfile().unwrap();
@@ -3457,18 +3457,19 @@ mod tests {
34573457
let batch = batch.unwrap();
34583458
row_count += batch.num_rows();
34593459

3460-
let binary_col = batch.column(0).as_binary::<i32>();
3460+
let string_col = batch.column(0).as_string_opt::<i32>().unwrap();
34613461

3462-
for (i, x) in binary_col.iter().enumerate() {
3463-
assert_eq!(x.is_some(), i % 2 == 0);
3462+
let mut valid_count = 0;
3463+
for (i, x) in string_col.iter().enumerate() {
34643464
if let Some(x) = x {
3465-
assert_eq!(&x[0..7], b"parquet");
3465+
valid_count += 1;
3466+
assert_eq!(x, "parquet");
34663467
}
34673468
}
3469+
assert_eq!(valid_count, 7);
34683470
}
34693471

34703472
assert_eq!(row_count, file_metadata.num_rows() as usize);
3471-
todo!("add tests")
34723473
}
34733474

34743475
#[test]

0 commit comments

Comments
 (0)