Skip to content

Commit

Permalink
Try and clarify
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb committed Nov 4, 2023
1 parent c2b7469 commit 7ca8a9b
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions datafusion/physical-expr/src/partitioning.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
/// ...
/// ```
///
Expand Down

0 comments on commit 7ca8a9b

Please sign in to comment.