You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by gi...@apache.org on 2026/07/17 11:34:54 UTC
(datafusion) 01/01: chore: Fix duplicated word typos in comments (#23662)
This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/main/pr-23662-78be510e90821c748fcf4e3445d00cfa9165d860
in repository https://gitbox.apache.org/repos/asf/datafusion.git
commit bf948c9245983589410b3263857d57fe9a5451e4
Author: jackylee <qc...@gmail.com>
AuthorDate: Fri Jul 17 19:34:30 2026 +0800
chore: Fix duplicated word typos in comments (#23662)
## Which issue does this PR close?
N/A
## Rationale for this change
Remove duplicated words (e.g. `that that`, `of of`, `are are`) in code
comments and doc comments.
## What changes are included in this PR?
Fix duplicated word typos in comments only, no functional change.
## Are these changes tested?
No functional change, covered by existing tests.
## Are there any user-facing changes?
No.
---
datafusion-examples/examples/data_io/parquet_embedded_index.rs | 2 +-
datafusion/common/src/pruning.rs | 2 +-
datafusion/common/src/test_util.rs | 2 +-
datafusion/core/tests/user_defined/user_defined_plan.rs | 2 +-
datafusion/datasource-arrow/src/source.rs | 2 +-
datafusion/datasource-csv/src/file_format.rs | 2 +-
datafusion/expr/src/logical_plan/plan.rs | 10 +++++-----
datafusion/physical-expr/src/aggregate.rs | 2 +-
datafusion/physical-expr/src/window/standard.rs | 2 +-
.../src/joins/piecewise_merge_join/classic_join.rs | 2 +-
10 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/datafusion-examples/examples/data_io/parquet_embedded_index.rs b/datafusion-examples/examples/data_io/parquet_embedded_index.rs
index 40b5b468ff..a8a3c97fa1 100644
--- a/datafusion-examples/examples/data_io/parquet_embedded_index.rs
+++ b/datafusion-examples/examples/data_io/parquet_embedded_index.rs
@@ -87,7 +87,7 @@
//! 2. Read and deserialize the index.
//!
//! 3. Create a `TableProvider` that knows how to use the index to quickly find
-//! the relevant files, row groups, data pages or rows based on on pushed down
+//! the relevant files, row groups, data pages or rows based on pushed down
//! filters.
//!
//! # FAQ: Why do other Parquet readers skip over the custom index?
diff --git a/datafusion/common/src/pruning.rs b/datafusion/common/src/pruning.rs
index ebae23f072..a36ac9f795 100644
--- a/datafusion/common/src/pruning.rs
+++ b/datafusion/common/src/pruning.rs
@@ -305,7 +305,7 @@ impl PruningStatistics for PartitionPruningStatistics {
/// that has statistics of its columns.
///
/// It is up to the caller to decide what each container represents. For
-/// example, they can come from a file (e.g. [`PartitionedFile`]) or a set of of
+/// example, they can come from a file (e.g. [`PartitionedFile`]) or a set of
/// files (e.g. [`FileGroup`])
///
/// [`PartitionedFile`]: https://docs.rs/datafusion/latest/datafusion/datasource/listing/struct.PartitionedFile.html
diff --git a/datafusion/common/src/test_util.rs b/datafusion/common/src/test_util.rs
index 8ad1e086bc..3d645c4254 100644
--- a/datafusion/common/src/test_util.rs
+++ b/datafusion/common/src/test_util.rs
@@ -174,7 +174,7 @@ macro_rules! assert_contains {
}
/// A macro to assert that one string is NOT contained within another with
-/// a nice error message if they are are.
+/// a nice error message if they are.
///
/// Usage: `assert_not_contains!(actual, unexpected)`
///
diff --git a/datafusion/core/tests/user_defined/user_defined_plan.rs b/datafusion/core/tests/user_defined/user_defined_plan.rs
index b837373632..75738bcfe1 100644
--- a/datafusion/core/tests/user_defined/user_defined_plan.rs
+++ b/datafusion/core/tests/user_defined/user_defined_plan.rs
@@ -518,7 +518,7 @@ impl OptimizerRule for TopKOptimizerRule {
if let LogicalPlan::Sort(Sort { expr, input, .. }) = limit.input.as_ref()
&& expr.len() == 1
{
- // we found a sort with a single sort expr, replace with a a TopK
+ // we found a sort with a single sort expr, replace with a TopK
return Ok(Transformed::yes(LogicalPlan::Extension(Extension {
node: Arc::new(TopKPlanNode {
k: fetch,
diff --git a/datafusion/datasource-arrow/src/source.rs b/datafusion/datasource-arrow/src/source.rs
index 59c020c779..27533052ce 100644
--- a/datafusion/datasource-arrow/src/source.rs
+++ b/datafusion/datasource-arrow/src/source.rs
@@ -340,7 +340,7 @@ impl FileSource for ArrowSource {
// The Arrow IPC stream format doesn't support range-based parallel reading
// because it lacks a footer with the information that would be needed to
// make range-based parallel reading practical. Without the data in the
- // footer you would either need to read the the entire file and record the
+ // footer you would either need to read the entire file and record the
// offsets of the record batches and dictionaries, essentially recreating
// the footer's contents, or else each partition would need to read the
// entire file up to the correct offset which is a lot of duplicate I/O.
diff --git a/datafusion/datasource-csv/src/file_format.rs b/datafusion/datasource-csv/src/file_format.rs
index 6b131f2bee..89c3d374e6 100644
--- a/datafusion/datasource-csv/src/file_format.rs
+++ b/datafusion/datasource-csv/src/file_format.rs
@@ -168,7 +168,7 @@ impl CsvFormat {
stream.boxed()
}
- /// Convert a stream of bytes into a stream of of [`Bytes`] containing newline
+ /// Convert a stream of bytes into a stream of [`Bytes`] containing newline
/// delimited CSV records, while accounting for `\` and `"`.
pub async fn read_to_delimited_chunks_from_stream<'a>(
&self,
diff --git a/datafusion/expr/src/logical_plan/plan.rs b/datafusion/expr/src/logical_plan/plan.rs
index b6e6cc7683..9cfab21a03 100644
--- a/datafusion/expr/src/logical_plan/plan.rs
+++ b/datafusion/expr/src/logical_plan/plan.rs
@@ -1733,7 +1733,7 @@ impl LogicalPlan {
/// ```
pub fn display_indent(&self) -> impl Display + '_ {
// Boilerplate structure to wrap LogicalPlan with something
- // that that can be formatted
+ // that can be formatted
struct Wrapper<'a>(&'a LogicalPlan);
impl Display for Wrapper<'_> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
@@ -1779,7 +1779,7 @@ impl LogicalPlan {
/// ```
pub fn display_indent_schema(&self) -> impl Display + '_ {
// Boilerplate structure to wrap LogicalPlan with something
- // that that can be formatted
+ // that can be formatted
struct Wrapper<'a>(&'a LogicalPlan);
impl Display for Wrapper<'_> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
@@ -1799,7 +1799,7 @@ impl LogicalPlan {
/// Users can use this format to visualize the plan in existing plan visualization tools, for example [dalibo](https://explain.dalibo.com/)
pub fn display_pg_json(&self) -> impl Display + '_ {
// Boilerplate structure to wrap LogicalPlan with something
- // that that can be formatted
+ // that can be formatted
struct Wrapper<'a>(&'a LogicalPlan);
impl Display for Wrapper<'_> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
@@ -1845,7 +1845,7 @@ impl LogicalPlan {
/// ```
pub fn display_graphviz(&self) -> impl Display + '_ {
// Boilerplate structure to wrap LogicalPlan with something
- // that that can be formatted
+ // that can be formatted
struct Wrapper<'a>(&'a LogicalPlan);
impl Display for Wrapper<'_> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
@@ -1896,7 +1896,7 @@ impl LogicalPlan {
/// ```
pub fn display(&self) -> impl Display + '_ {
// Boilerplate structure to wrap LogicalPlan with something
- // that that can be formatted
+ // that can be formatted
struct Wrapper<'a>(&'a LogicalPlan);
impl Display for Wrapper<'_> {
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
diff --git a/datafusion/physical-expr/src/aggregate.rs b/datafusion/physical-expr/src/aggregate.rs
index e5d55aba4f..b774658679 100644
--- a/datafusion/physical-expr/src/aggregate.rs
+++ b/datafusion/physical-expr/src/aggregate.rs
@@ -858,7 +858,7 @@ impl AggregateFunctionExpr {
// `retract_batch` method will not be called. In this case
// having retract_batch is not a requirement.
//
- // This approach is a a bit different than window function
+ // This approach is a bit different than window function
// approach. In window function (when they use a window frame)
// they get all the desired range during evaluation.
if !accumulator.supports_retract_batch() {
diff --git a/datafusion/physical-expr/src/window/standard.rs b/datafusion/physical-expr/src/window/standard.rs
index 46f3cabbad..6f61174ee0 100644
--- a/datafusion/physical-expr/src/window/standard.rs
+++ b/datafusion/physical-expr/src/window/standard.rs
@@ -128,7 +128,7 @@ impl WindowExpr for StandardWindowExpr {
let mut window_frame_ctx =
WindowFrameContext::new(Arc::clone(&self.window_frame), sort_options);
let mut last_range = Range { start: 0, end: 0 };
- // We iterate on each row to calculate window frame range and and window function result
+ // We iterate on each row to calculate window frame range and window function result
for idx in 0..num_rows {
let range = window_frame_ctx.calculate_range(
order_bys_ref,
diff --git a/datafusion/physical-plan/src/joins/piecewise_merge_join/classic_join.rs b/datafusion/physical-plan/src/joins/piecewise_merge_join/classic_join.rs
index 36a043cc7d..50ef78f18b 100644
--- a/datafusion/physical-plan/src/joins/piecewise_merge_join/classic_join.rs
+++ b/datafusion/physical-plan/src/joins/piecewise_merge_join/classic_join.rs
@@ -125,7 +125,7 @@ impl RecordBatchStream for ClassicPWMJStream {
// Classic Joins
// 1. `WaitBufferedSide` - Load in the buffered side data into memory.
// 2. `FetchStreamBatch` - Fetch + sort incoming stream batches. We switch the state to
-// `Completed` if there are are still remaining partitions to process. It is only switched to
+// `Completed` if there are still remaining partitions to process. It is only switched to
// `ExhaustedStreamBatch` if all partitions have been processed.
// 3. `ProcessStreamBatch` - Compare stream batch row values against the buffered side data.
// 4. `ExhaustedStreamBatch` - If the join type is Left or Inner we will return state as
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org