apache · CuteChuanChuan · Nov 8, 2025
diff --git a/datafusion/core/src/lib.rs b/datafusion/core/src/lib.rs
@@ -487,7 +487,7 @@
 //! consumes it immediately as well.
 //!
 //! ```text
-//!
+//! 
 //! Step 3: FilterExec calls next()       Step 2: ProjectionExec calls
 //!         on input Stream                  next() on input Stream
 //!         ┌ ─ ─ ─ ─ ─ ─ ─ ─ ─      ┌ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┐

diff --git a/datafusion/doc/src/lib.rs b/datafusion/doc/src/lib.rs
@@ -196,7 +196,7 @@ impl Default for DocSection {
 /// Example:
 ///
 /// ```rust
-///
+/// 
 /// # fn main() {
 ///     use datafusion_doc::{DocSection, Documentation};
 ///     let doc_section = DocSection {

diff --git a/datafusion/functions-aggregate-common/src/tdigest.rs b/datafusion/functions-aggregate-common/src/tdigest.rs
@@ -554,7 +554,7 @@ impl TDigest {
     /// [`ScalarValue::Float64`]:
     ///
     /// ```text
-    ///
+    /// 
     ///    ┌────────┬────────┬────────┬───────┬────────┬────────┐
     ///    │max_size│  sum   │ count  │  max  │  min   │centroid│
     ///    └────────┴────────┴────────┴───────┴────────┴────────┘

diff --git a/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/mod.rs b/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/mod.rs
@@ -180,7 +180,6 @@ pub struct GroupValuesColumn<const STREAMING: bool> {
     /// We don't really store the actual `group values` in `hashtable`,
     /// instead we store the `group indices` pointing to values in `GroupValues`.
     /// And we use [`GroupIndexView`] to represent such `group indices` in table.
-    ///
     map: HashTable<(u64, GroupIndexView)>,
 
     /// The size of `map` in bytes

diff --git a/datafusion/physical-plan/src/aggregates/row_hash.rs b/datafusion/physical-plan/src/aggregates/row_hash.rs
@@ -219,7 +219,7 @@ impl SkipAggregationProbe {
 /// # Architecture
 ///
 /// ```text
-///
+/// 
 ///     Assigns a consecutive group           internally stores aggregate values
 ///     index for each unique set                     for all groups
 ///         of group values

diff --git a/datafusion/physical-plan/src/joins/hash_join/exec.rs b/datafusion/physical-plan/src/joins/hash_join/exec.rs
@@ -213,7 +213,7 @@ impl JoinLeftData {
 ///
 ///
 /// ```text
-///
+/// 
 ///  Original build-side data   Inserting build-side values into hashmap    Concatenated build-side batch
 ///                                                                         ┌───────────────────────────┐
 ///                             hashmap.insert(row-hash, row-idx + offset)  │                      idx  │

diff --git a/datafusion/physical-plan/src/joins/hash_join/stream.rs b/datafusion/physical-plan/src/joins/hash_join/stream.rs
@@ -107,7 +107,7 @@ impl BuildSide {
 /// Expected state transitions performed by HashJoinStream are:
 ///
 /// ```text
-///
+/// 
 ///       WaitBuildSide
 ///             │
 ///             ▼

diff --git a/datafusion/physical-plan/src/sorts/cursor.rs b/datafusion/physical-plan/src/sorts/cursor.rs
@@ -52,7 +52,7 @@ pub trait CursorValues {
 /// [`CursorValues`]
 ///
 /// ```text
-///
+/// 
 /// ┌───────────────────────┐
 /// │                       │           ┌──────────────────────┐
 /// │ ┌─────────┐ ┌─────┐   │    ─ ─ ─ ─│      Cursor<T>       │

diff --git a/datafusion/physical-plan/src/unnest.rs b/datafusion/physical-plan/src/unnest.rs
@@ -598,7 +598,7 @@ struct UnnestingResult {
 /// ```
 /// Result:
 /// ```text
-///
+/// 
 ///     ┌────────────────────────────────────────────────┬────────────────────────────────────────────────┐
 ///     │ unnest(i, "recursive" := CAST('t' AS BOOLEAN)) │ unnest(j, "recursive" := CAST('t' AS BOOLEAN)) │
 ///     │                     int32                      │                     int32                      │
-Original file line number
+Diff line change
@@ Expand Up / @@ -107,7 +107,7 @@ impl BuildSide { @@
     /// Expected state transitions performed by HashJoinStream are:
     ///
     /// ```text
-    ///
+    ///
     ///       WaitBuildSide
     ///             │
     ///             ▼
@@ Expand Down @@