Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
thomas-k-cameron committed Dec 10, 2023
1 parent ac00cfa commit 03690ab
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions datafusion/core/src/datasource/file_format/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -696,15 +696,15 @@ mod tests {
assert_eq!(stats.num_rows, Some(3));
let c1_stats = &stats.column_statistics.as_ref().expect("missing c1 stats")[0];
let c2_stats = &stats.column_statistics.as_ref().expect("missing c2 stats")[1];
assert_eq!(c1_stats.null_count, Some(1));
assert_eq!(c2_stats.null_count, Some(3));
assert_eq!(c1_stats.null_count, Some(3));
assert_eq!(c2_stats.null_count, Some(1));

let stats = fetch_statistics(store.as_ref(), schema, &meta[1], None).await?;
assert_eq!(stats.num_rows, Some(3));
let c1_stats = &stats.column_statistics.as_ref().expect("missing c1 stats")[0];
let c2_stats = &stats.column_statistics.as_ref().expect("missing c2 stats")[1];
assert_eq!(c1_stats.null_count, Some(3));
assert_eq!(c2_stats.null_count, Some(1));
assert_eq!(c1_stats.null_count, Some(1));
assert_eq!(c2_stats.null_count, Some(3));
assert_eq!(c2_stats.max_value, Some(ScalarValue::Int64(Some(2))));
assert_eq!(c2_stats.min_value, Some(ScalarValue::Int64(Some(1))));

Expand Down

0 comments on commit 03690ab

Please sign in to comment.