Fix build failure

Author: Subham Singhal

datafusion/common/src/config.rs

@@ -1147,6 +1147,12 @@ config_namespace! {
         ///
         /// Default: true
         pub enable_sort_pushdown: bool, default = true
+
+        /// When set to true, the optimizer will extract leaf expressions
+        /// (such as `get_field`) from filter/sort/join nodes into projections
+        /// closer to the leaf table scans, and push those projections down
+        /// towards the leaf nodes.
+        pub enable_leaf_expression_pushdown: bool, default = true
     }
 }
 
@@ -3070,6 +3076,22 @@ config_namespace! {
         /// If not specified, the default level for the compression algorithm is used.
         pub compression_level: Option<u32>, default = None
         pub schema_infer_max_rec: Option<usize>, default = None
+         /// The JSON format to use when reading files.
+         ///
+         /// When `true` (default), expects newline-delimited JSON (NDJSON):
+         /// ```text
+         /// {"key1": 1, "key2": "val"}
+         /// {"key1": 2, "key2": "vals"}
+         /// ```
+         ///
+         /// When `false`, expects JSON array format:
+         /// ```text
+         /// [
+         ///   {"key1": 1, "key2": "val"},
+         ///   {"key1": 2, "key2": "vals"}
+         /// ]
+         /// ```
+        pub newline_delimited: bool, default = true
     }
 }
 

datafusion/common/src/file_options/parquet_writer.rs

@@ -461,6 +461,7 @@ mod tests {
             skip_arrow_metadata: defaults.skip_arrow_metadata,
             coerce_int96: None,
             max_predicate_cache_size: defaults.max_predicate_cache_size,
+            field_id_read_enabled: defaults.field_id_read_enabled,
         }
     }
 
@@ -575,6 +576,7 @@ mod tests {
                 binary_as_string: global_options_defaults.binary_as_string,
                 skip_arrow_metadata: global_options_defaults.skip_arrow_metadata,
                 coerce_int96: None,
+                field_id_read_enabled: global_options_defaults.field_id_read_enabled,
             },
             column_specific_options,
             key_value_metadata,

datafusion/datasource-parquet/src/metadata.rs

@@ -83,7 +83,7 @@ pub struct DFParquetMetadata<'a> {
 /// field IDs at all nesting levels. See PARQUET_FIELD_ID_IMPLEMENTATION.md
 /// for details on nested schema support.
 fn add_field_ids_to_arrow_schema(
-    arrow_schema: Schema,
+    arrow_schema: &Schema,
     parquet_schema: &SchemaDescriptor,
 ) -> Result<Schema> {
     use arrow::datatypes::Field;
@@ -244,7 +244,8 @@ impl<'a> DFParquetMetadata<'a> {
 
         // Add field IDs if requested
         if self.enable_field_ids {
-            schema = add_field_ids_to_arrow_schema(schema, file_metadata.schema_descr())?;
+            schema =
+                add_field_ids_to_arrow_schema(&schema, file_metadata.schema_descr())?;
         }
 
         // Apply INT96 coercion if configured

datafusion/physical-expr/src/utils/mod.rs

@@ -295,10 +295,10 @@ fn find_field_index(
         // TODO: For nested schemas, this needs to recursively match field IDs
         // through the struct hierarchy
         for (idx, target_field) in target_schema.fields().iter().enumerate() {
-            if let Some(target_field_id) = get_field_id(target_field) {
-                if source_field_id == target_field_id {
-                    return Ok(idx);
-                }
+            if let Some(target_field_id) = get_field_id(target_field)
+                && source_field_id == target_field_id
+            {
+                return Ok(idx);
             }
         }
     }

datafusion/proto-common/src/from_proto/mod.rs

@@ -1090,6 +1090,7 @@ impl TryFrom<&protobuf::ParquetOptions> for ParquetOptions {
             max_predicate_cache_size: value.max_predicate_cache_size_opt.map(|opt| match opt {
                 protobuf::parquet_options::MaxPredicateCacheSizeOpt::MaxPredicateCacheSize(v) => Some(v as usize),
             }).unwrap_or(None),
+            field_id_read_enabled: false, // Default value
         })
     }
 }

datafusion/proto/src/logical_plan/file_formats.rs

@@ -525,6 +525,7 @@ mod parquet {
             max_predicate_cache_size: proto.max_predicate_cache_size_opt.as_ref().map(|opt| match opt {
                 parquet_options::MaxPredicateCacheSizeOpt::MaxPredicateCacheSize(size) => *size as usize,
             }),
+                field_id_read_enabled: false,
         }
         }
     }