Skip to content

Commit d215831

Browse files
committed
Fix some tests
1 parent 547110d commit d215831

File tree

3 files changed

+8
-7
lines changed

3 files changed

+8
-7
lines changed

crates/iceberg/src/expr/visitors/manifest_evaluator.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ impl BoundPredicateVisitor for ManifestFilterVisitor<'_> {
258258
lower_bound_bytes,
259259
*reference.field().field_type.clone(),
260260
);
261-
if datum > &lower_bound {
261+
if &lower_bound > datum {
262262
return ROWS_CANNOT_MATCH;
263263
}
264264
}
@@ -268,7 +268,7 @@ impl BoundPredicateVisitor for ManifestFilterVisitor<'_> {
268268
upper_bound_bytes,
269269
*reference.field().field_type.clone(),
270270
);
271-
if datum < &upper_bound {
271+
if &upper_bound < datum {
272272
return ROWS_CANNOT_MATCH;
273273
}
274274
}
@@ -381,21 +381,21 @@ impl BoundPredicateVisitor for ManifestFilterVisitor<'_> {
381381
}
382382

383383
if let Some(lower_bound) = &field.lower_bound {
384-
let d = ManifestFilterVisitor::bytes_to_datum(
384+
let lower_bound = ManifestFilterVisitor::bytes_to_datum(
385385
lower_bound,
386386
*reference.field().clone().field_type,
387387
);
388-
if literals.iter().all(|datum| &d < datum) {
388+
if literals.iter().all(|datum| &lower_bound > datum) {
389389
return ROWS_CANNOT_MATCH;
390390
}
391391
}
392392

393393
if let Some(upper_bound) = &field.upper_bound {
394-
let d = ManifestFilterVisitor::bytes_to_datum(
394+
let upper_bound = ManifestFilterVisitor::bytes_to_datum(
395395
upper_bound,
396396
*reference.field().clone().field_type,
397397
);
398-
if literals.iter().all(|datum| &d < datum) {
398+
if literals.iter().all(|datum| &upper_bound < datum) {
399399
return ROWS_CANNOT_MATCH;
400400
}
401401
}

crates/iceberg/src/inspect/manifests.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -261,6 +261,7 @@ impl<'a> ManifestsTable<'a> {
261261
.field_type
262262
.as_primitive_type()
263263
.unwrap();
264+
264265
partition_summaries_builder
265266
.field_builder::<StringBuilder>(2)
266267
.unwrap()

crates/iceberg/src/spec/manifest_list.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1144,7 +1144,7 @@ mod test {
11441144
added_rows_count: Some(3),
11451145
existing_rows_count: Some(0),
11461146
deleted_rows_count: Some(0),
1147-
partitions: Some(vec![]),
1147+
partitions: None,
11481148
key_metadata: vec![],
11491149
}]
11501150
}.try_into().unwrap();

0 commit comments

Comments
 (0)