Apply nightly rustfmt formatting to doc comment code examples

Author: CuteChuanChuan

.github/workflows/rust.yml

@@ -587,7 +587,7 @@ jobs:
         uses: ./.github/actions/setup-builder
         with:
           rust-version: stable
-      - name: Run cargo fmt check (including doc comments)
+      - name: Run
         run: |
           echo '' > datafusion/proto/src/generated/datafusion.rs
           ci/scripts/rust_fmt.sh

datafusion/core/src/dataframe/mod.rs

@@ -1380,6 +1380,7 @@ impl DataFrame {
     ///     .read_csv("tests/data/example.csv", CsvReadOptions::new())
     ///     .await?;
     /// let count = df.count().await?; // 1
+    ///     
     /// # assert_eq!(count, 1);
     /// # Ok(())
     /// # }

datafusion/core/src/execution/context/mod.rs

@@ -443,7 +443,7 @@ impl SessionContext {
     /// # use datafusion::execution::SessionStateBuilder;
     /// # use datafusion_optimizer::push_down_filter::PushDownFilter;
     /// let my_rule = PushDownFilter {}; // pretend it is a new rule
-    ///                                  // Create a new builder with a custom optimizer rule
+    /// // Create a new builder with a custom optimizer rule
     /// let context: SessionContext = SessionStateBuilder::new()
     ///     .with_optimizer_rule(Arc::new(my_rule))
     ///     .build()
@@ -635,9 +635,10 @@ impl SessionContext {
     ///     .sql_with_options("CREATE TABLE foo (x INTEGER)", options)
     ///     .await
     ///     .unwrap_err();
-    /// assert!(err
-    ///     .to_string()
-    ///     .starts_with("Error during planning: DDL not supported: CreateMemoryTable"));
+    /// assert!(
+    ///     err.to_string()
+    ///         .starts_with("Error during planning: DDL not supported: CreateMemoryTable")
+    /// );
     /// # Ok(())
     /// # }
     /// ```

datafusion/datasource-parquet/src/access_plan.rs

@@ -42,11 +42,11 @@ use parquet::file::metadata::RowGroupMetaData;
 /// // Use parquet reader RowSelector to specify scanning rows 100-200 and 350-400
 /// // in a row group that has 1000 rows
 /// let row_selection = RowSelection::from(vec![
-///    RowSelector::skip(100),
-///    RowSelector::select(100),
-///    RowSelector::skip(150),
-///    RowSelector::select(50),
-///    RowSelector::skip(600),  // skip last 600 rows
+///     RowSelector::skip(100),
+///     RowSelector::select(100),
+///     RowSelector::skip(150),
+///     RowSelector::select(50),
+///     RowSelector::skip(600), // skip last 600 rows
 /// ]);
 /// access_plan.scan_selection(1, row_selection);
 /// access_plan.skip(2); // skip row group 2

datafusion/physical-plan/src/sort_pushdown.rs

@@ -100,15 +100,24 @@ impl<T> SortOrderPushdownResult<T> {
     /// # use datafusion_physical_plan::SortOrderPushdownResult;
     /// let exact = SortOrderPushdownResult::Exact { inner: 42 };
     /// let inexact = exact.into_inexact();
-    /// assert!(matches!(inexact, SortOrderPushdownResult::Inexact { inner: 42 }));
+    /// assert!(matches!(
+    ///     inexact,
+    ///     SortOrderPushdownResult::Inexact { inner: 42 }
+    /// ));
     ///
     /// let already_inexact = SortOrderPushdownResult::Inexact { inner: 42 };
     /// let still_inexact = already_inexact.into_inexact();
-    /// assert!(matches!(still_inexact, SortOrderPushdownResult::Inexact { inner: 42 }));
+    /// assert!(matches!(
+    ///     still_inexact,
+    ///     SortOrderPushdownResult::Inexact { inner: 42 }
+    /// ));
     ///
     /// let unsupported = SortOrderPushdownResult::<i32>::Unsupported;
     /// let still_unsupported = unsupported.into_inexact();
-    /// assert!(matches!(still_unsupported, SortOrderPushdownResult::Unsupported));
+    /// assert!(matches!(
+    ///     still_unsupported,
+    ///     SortOrderPushdownResult::Unsupported
+    /// ));
     /// ```
     pub fn into_inexact(self) -> Self {
         match self {

datafusion/proto/src/bytes/mod.rs

@@ -47,7 +47,7 @@ mod registry;
 /// bytes.
 ///
 /// ```
-/// use datafusion_expr::{col, lit, Expr};
+/// use datafusion_expr::{Expr, col, lit};
 /// use datafusion_proto::bytes::Serializeable;
 ///
 /// // Create a new `Expr` a < 32