From 3dea9a4a97689d751b6aed58dbd02f6e24363302 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9E=97=E4=BC=9F?= Date: Sat, 11 Nov 2023 11:13:28 +0800 Subject: [PATCH 1/2] Fix typo in partitioning.rs --- datafusion/physical-expr/src/partitioning.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/physical-expr/src/partitioning.rs b/datafusion/physical-expr/src/partitioning.rs index cbacb7a8a906..abacb89a08fc 100644 --- a/datafusion/physical-expr/src/partitioning.rs +++ b/datafusion/physical-expr/src/partitioning.rs @@ -26,7 +26,7 @@ use crate::{physical_exprs_equal, EquivalenceProperties, PhysicalExpr}; /// /// When `executed`, `ExecutionPlan`s produce one or more independent stream of /// data batches in parallel, referred to as partitions. The streams are Rust -/// `aync` [`Stream`]s (a special kind of future). The number of output +/// `async` [`Stream`]s (a special kind of future). The number of output /// partitions varies based on the input and the operation performed. /// /// For example, an `ExecutionPlan` that has output partitioning of 3 will From ca55c4648b6fb72e4af46d7b33604316eb988114 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9E=97=E4=BC=9F?= Date: Sat, 11 Nov 2023 11:16:53 +0800 Subject: [PATCH 2/2] Update partitioning.rs --- datafusion/physical-expr/src/partitioning.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/physical-expr/src/partitioning.rs b/datafusion/physical-expr/src/partitioning.rs index abacb89a08fc..301f12e9aa2e 100644 --- a/datafusion/physical-expr/src/partitioning.rs +++ b/datafusion/physical-expr/src/partitioning.rs @@ -64,7 +64,7 @@ use crate::{physical_exprs_equal, EquivalenceProperties, PhysicalExpr}; /// ``` /// /// It is common (but not required) that an `ExecutionPlan` has the same number -/// of input partitions as output partitons. However, some plans have different +/// of input partitions as output partitions. However, some plans have different /// numbers such as the `RepartitionExec` that redistributes batches from some /// number of inputs to some number of outputs ///