cargo fmt

Author: kosiew

datafusion/physical-expr/src/expressions/cast.rs

@@ -177,7 +177,8 @@ impl CastExpr {
     }
 
     fn preserves_child_field_semantics(&self, input_schema: &Schema) -> Result<bool> {
-        Ok(self.resolved_target_field(input_schema)? == self.expr.return_field(input_schema)?)
+        Ok(self.resolved_target_field(input_schema)?
+            == self.expr.return_field(input_schema)?)
     }
 
     /// Check if casting from the specified source type to the target type is a
@@ -347,7 +348,9 @@ pub(crate) fn cast_with_target_field_and_options(
         cast_options.clone(),
     );
 
-    if expr_type == *cast_type && candidate.preserves_child_field_semantics(input_schema)? {
+    if expr_type == *cast_type
+        && candidate.preserves_child_field_semantics(input_schema)?
+    {
         return Ok(Arc::clone(&expr));
     }
 
@@ -930,15 +933,15 @@ mod tests {
     #[test]
     fn field_aware_same_type_cast_preserves_explicit_target_field() -> Result<()> {
         let schema = Schema::new(vec![Field::new("a", Int32, false)]);
-        let expr = cast_with_target_field_and_options(
-            col("a", &schema)?,
-            &schema,
-            Arc::new(Field::new("logical_a", Int32, true).with_metadata(HashMap::from([(
-                "target_meta".to_string(),
-                "1".to_string(),
-            )]))),
-            None,
-        )?;
+        let expr =
+            cast_with_target_field_and_options(
+                col("a", &schema)?,
+                &schema,
+                Arc::new(Field::new("logical_a", Int32, true).with_metadata(
+                    HashMap::from([("target_meta".to_string(), "1".to_string())]),
+                )),
+                None,
+            )?;
 
         let cast_expr = expr
             .as_any()

datafusion/physical-expr/src/planner.rs

@@ -542,7 +542,8 @@ mod tests {
     }
 
     #[test]
-    fn test_create_physical_expr_same_type_cast_preserves_explicit_target_field() -> Result<()> {
+    fn test_create_physical_expr_same_type_cast_preserves_explicit_target_field()
+    -> Result<()> {
         let schema = Schema::new(vec![Field::new("value", DataType::Int32, false)]);
         let df_schema = DFSchema::try_from(schema.clone())?;
         let target_field = Arc::new(
@@ -563,7 +564,10 @@ mod tests {
             .downcast_ref::<CastExpr>()
             .expect("same-type cast with explicit field should preserve CastExpr");
         assert_eq!(cast_expr.target_field(), &target_field);
-        assert_eq!(physical_expr.return_field(&schema)?.name(), "same_type_cast");
+        assert_eq!(
+            physical_expr.return_field(&schema)?.name(),
+            "same_type_cast"
+        );
 
         Ok(())
     }