From 7ca8a9be1fa69040007970d4ecd5a5c73e12bf9b Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Sat, 4 Nov 2023 06:38:21 -0400 Subject: [PATCH] Try and clarify --- datafusion/physical-expr/src/partitioning.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/datafusion/physical-expr/src/partitioning.rs b/datafusion/physical-expr/src/partitioning.rs index 6000ad539ade..4f51a336effb 100644 --- a/datafusion/physical-expr/src/partitioning.rs +++ b/datafusion/physical-expr/src/partitioning.rs @@ -58,8 +58,9 @@ use crate::{expr_list_eq_strict_order, EquivalenceProperties, PhysicalExpr}; /// │ │ │ /// │ │ │ /// -// ExecutionPlan with 3 output 3 (async) streams, one for each -// partitions output partition +/// ExecutionPlan with 1 input 3 (async) streams, one for each +/// that has 3 partitions, which itself output partition +/// has 3 output partitions /// ``` /// /// It is common (but not required) that an `ExecutionPlan` has the same number @@ -83,9 +84,9 @@ use crate::{expr_list_eq_strict_order, EquivalenceProperties, PhysicalExpr}; /// └──────────┐│┌──────────┘ /// │││ /// │││ -/// RepartitionExec with 3 output -/// partitions and 1 input partition 3 (async) streams, that internally -/// pull from the same input stream +/// RepartitionExec with one input +/// that has 3 partitions, but 3 (async) streams, that internally +/// itself has only 1 output partition pull from the same input stream /// ... /// ``` ///