Skip to content

Commit 080ce15

Browse files
fix comment on DistributedLeafExec (#507)
1 parent 61c3f8d commit 080ce15

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/execution_plans/distributed_leaf.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,8 @@ pub struct DistributedLeafExec {
6969

7070
impl DistributedLeafExec {
7171
/// Builds a new [DistributedLeafExec] based on the provided original plan and its per-task
72-
/// variants. Provided variants must expose the same partition count as the original plan.
72+
/// variants. Every variant must expose the same schema and partition count as every other
73+
/// variant.
7374
pub fn try_new(
7475
original: Arc<dyn ExecutionPlan>,
7576
variants: impl IntoIterator<Item = Arc<dyn ExecutionPlan>>,

0 commit comments

Comments
 (0)