Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
JackTan25 committed Dec 13, 2023
1 parent 429b7b0 commit 78ae91f
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -408,7 +408,7 @@ impl MergeIntoInterpreter {
}));
// if change_join_order = true, it means the target is build side,
// in this way, we will do matched operation and not matched operation
// locally in every node, and the main node just recieve rowids to apply.
// locally in every node, and the main node just receive rowids to apply.
let segments = if *change_join_order {
segments.clone()
} else {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,12 +105,12 @@ impl PipelineBuilder {

// there are two cases:
// 1. if source is build side (change_join_order = false).
// receive row numbers and MutationLogs, excatly below:
// receive row numbers and MutationLogs, exactly below:
// 1.1 full operation: row numbers and MutationLogs
// 1.2 matched only: MutationLogs
// 1.3 insert only: row numbers and MutationLogs
// 2. if target table is build side (change_join_order = true).
// receive rowids and MutationLogs,excatly below:
// receive rowids and MutationLogs,exactly below:
// 2.1 full operation: rowids and MutationLogs
// 2.2 matched only: rowids and MutationLogs
// 2.3 insert only: MutationLogs
Expand Down Expand Up @@ -262,7 +262,7 @@ impl PipelineBuilder {
// we will receive MutationLogs only without rowids.
return Ok(());
}
// we will recieve MutationLogs and rowids. So we should apply
// we will receive MutationLogs and rowids. So we should apply
// rowids firstly and then send all mutation logs to commit sink.
// we need to spilt rowid and mutationlogs, and we can get pipeitems:
// 1.rowid_port
Expand Down
2 changes: 1 addition & 1 deletion src/query/sql/src/planner/plans/merge_into.rs
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ impl std::fmt::Debug for MergeInto {
}
}

pub const INSERT_NAME: &str = "number of rows insertd";
pub const INSERT_NAME: &str = "number of rows inserted";
pub const UPDTAE_NAME: &str = "number of rows updated";
pub const DELETE_NAME: &str = "number of rows deleted";

Expand Down

0 comments on commit 78ae91f

Please sign in to comment.