From b77917747fc24d45173d4aed323302f4fda77a12 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9E=97=E4=BC=9F?= Date: Tue, 20 Aug 2024 00:00:29 +0800 Subject: [PATCH] Improve doc (#12053) --- datafusion/expr-common/src/accumulator.rs | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/datafusion/expr-common/src/accumulator.rs b/datafusion/expr-common/src/accumulator.rs index eac91c4f8efc..75335209451e 100644 --- a/datafusion/expr-common/src/accumulator.rs +++ b/datafusion/expr-common/src/accumulator.rs @@ -117,8 +117,8 @@ pub trait Accumulator: Send + Sync + Debug { /// ┌─────────────────────────┐ ┌─────────────────────────┐ /// │ GroubyBy │ │ GroubyBy │ /// │(AggregateMode::Partial) │ │(AggregateMode::Partial) │ - /// └─────────────────────────┘ └────────────▲────────────┘ - /// ▲ │ + /// └─────────────────────────┘ └─────────────────────────┘ + /// ▲ ▲ /// │ │ update_batch() is called for /// │ │ each input RecordBatch /// .─────────. .─────────. @@ -185,15 +185,15 @@ pub trait Accumulator: Send + Sync + Debug { /// │(AggregateMode::Partial) │ │ (AggregateMode::Partial) │ the groups /// └─────────────────────────┘ └──────────────────────────┘ /// ▲ ▲ - /// │ ┌┘ - /// │ │ - /// .─────────. .─────────. - /// ,─' '─. ,─' '─. - /// ; Input : ; Input : 1. Since input data is - /// : Partition 0 ; : Partition 1 ; arbitrarily or RoundRobin - /// ╲ ╱ ╲ ╱ distributed, each partition - /// '─. ,─' '─. ,─' likely has all distinct - /// `───────' `───────' + /// │ │ + /// │ │ + /// .─────────. .─────────. + /// ,─' '─. ,─' '─. + /// ; Input : ; Input : 1. Since input data is + /// : Partition 0 ; : Partition 1 ; arbitrarily or RoundRobin + /// ╲ ╱ ╲ ╱ distributed, each partition + /// '─. ,─' '─. ,─' likely has all distinct + /// `───────' `───────' /// ``` /// /// This structure is used so that the `AggregateMode::Partial` accumulators