We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8822f6d commit b8d5efdCopy full SHA for b8d5efd
1 file changed
src/execution_plans/distributed_leaf.rs
@@ -69,7 +69,8 @@ pub struct DistributedLeafExec {
69
70
impl DistributedLeafExec {
71
/// 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.
+ /// variants. Every variant must expose the same schema and partition count as every other
73
+ /// variant.
74
pub fn try_new(
75
original: Arc<dyn ExecutionPlan>,
76
variants: impl IntoIterator<Item = Arc<dyn ExecutionPlan>>,
0 commit comments