Skip to content

Commit 34188b6

Browse files
committed
DataFusion 52 migration
1 parent c1f03f5 commit 34188b6

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

native/core/src/parquet/schema_adapter.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -431,10 +431,9 @@ impl SchemaMapper for SchemaMapping {
431431
// If this field only exists in the table, and not in the file, then we need to
432432
// populate a default value for it.
433433
|| {
434-
if self.default_values.is_some() {
434+
if let Some(default_values) = &self.default_values {
435435
// We have a map of default values, see if this field is in there.
436-
if let Some(value) =
437-
self.default_values.as_ref().unwrap().get(&field_idx)
436+
if let Some(value) = default_values.get(&field_idx)
438437
// Default value exists, construct a column from it.
439438
{
440439
let cv = if field.data_type() == &value.data_type() {

0 commit comments

Comments
 (0)