Skip to content

Commit dfd3fd4

Browse files
committed
Last cleanup
1 parent 413a7e7 commit dfd3fd4

File tree

2 files changed

+5
-17
lines changed

2 files changed

+5
-17
lines changed

parquet-variant-compute/src/shred_variant.rs

Lines changed: 4 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -2221,10 +2221,7 @@ mod tests {
22212221
assert!(value_field.is_null(2));
22222222
assert!(value_field.is_valid(3));
22232223
assert_eq!(
2224-
Variant::new(
2225-
binary_array_value(result.metadata_field().as_ref(), 3).unwrap(),
2226-
binary_array_value(value_field.as_ref(), 3).unwrap()
2227-
),
2224+
variant_from_arrays_at(result.metadata_field(), value_field, 3).unwrap(),
22282225
Variant::from("not an object")
22292226
);
22302227
assert!(value_field.is_null(4));
@@ -2405,10 +2402,7 @@ mod tests {
24052402
assert_eq!(session_id_typed_value.value(1), mock_uuid_3.as_bytes());
24062403

24072404
// Verify the value field contains the name field
2408-
let row_1_variant = Variant::new(
2409-
binary_array_value(metadata.as_ref(), 1).unwrap(),
2410-
binary_array_value(value.as_ref(), 1).unwrap(),
2411-
);
2405+
let row_1_variant = variant_from_arrays_at(metadata, value, 1).unwrap();
24122406
let Variant::Object(obj) = row_1_variant else {
24132407
panic!("Expected object");
24142408
};
@@ -2440,10 +2434,7 @@ mod tests {
24402434

24412435
assert!(session_id_value.is_valid(3)); // type mismatch, stored in value
24422436
assert!(session_id_typed_value.is_null(3));
2443-
let session_id_variant = Variant::new(
2444-
binary_array_value(metadata.as_ref(), 3).unwrap(),
2445-
binary_array_value(session_id_value.as_ref(), 3).unwrap(),
2446-
);
2437+
let session_id_variant = variant_from_arrays_at(metadata, session_id_value, 3).unwrap();
24472438
assert_eq!(session_id_variant, Variant::from("not-a-uuid"));
24482439

24492440
// Row 4: Type mismatch - id is int64, not UUID
@@ -2454,10 +2445,7 @@ mod tests {
24542445

24552446
assert!(id_value.is_valid(4)); // type mismatch, stored in value
24562447
assert!(id_typed_value.is_null(4));
2457-
let id_variant = Variant::new(
2458-
binary_array_value(metadata.as_ref(), 4).unwrap(),
2459-
binary_array_value(id_value.as_ref(), 4).unwrap(),
2460-
);
2448+
let id_variant = variant_from_arrays_at(metadata, id_value, 4).unwrap();
24612449
assert_eq!(id_variant, Variant::from(12345i64));
24622450

24632451
assert!(session_id_value.is_null(4));

parquet-variant-compute/src/variant_array_builder.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,7 @@ mod test {
609609

610610
let array2 = VariantArray::from_parts(
611611
array.metadata_field().clone(),
612-
Some(Arc::new(value_builder.build().unwrap()) as ArrayRef),
612+
Some(Arc::new(value_builder.build().unwrap())),
613613
None,
614614
None,
615615
);

0 commit comments

Comments
 (0)