Skip to content

Commit ccdd363

Browse files
committed
simplify
1 parent de03b85 commit ccdd363

3 files changed

Lines changed: 387 additions & 434 deletions

File tree

datafusion/physical-plan/src/joins/sort_merge_join/exec.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -81,8 +81,7 @@ use datafusion_physical_expr_common::sort_expr::{LexOrdering, OrderingRequiremen
8181
/// on the output batch size of the execution plan. There is no spilling support for streamed input.
8282
/// The comparisons are performed from values of join keys in streamed input with the values of
8383
/// join keys in buffered input. One row in streamed record batch could be matched with multiple rows in
84-
/// buffered input batches. The streamed input is managed through the states in `StreamedState`
85-
/// and streamed input batches are represented by `StreamedBatch`.
84+
/// buffered input batches. Streamed input batches are represented by `StreamedBatch`.
8685
///
8786
/// Buffered input is buffered for all record batches having the same value of join key.
8887
/// If the memory limit increases beyond the specified value and spilling is enabled,
@@ -92,8 +91,7 @@ use datafusion_physical_expr_common::sort_expr::{LexOrdering, OrderingRequiremen
9291
/// memory/disk depends on the number of rows of buffered input having the same value
9392
/// of join key as that of streamed input rows currently present in memory. Due to pre-sorted inputs,
9493
/// the algorithm understands when it is not needed anymore, and releases the buffered batches
95-
/// from memory/disk. The buffered input is managed through the states in `BufferedState`
96-
/// and buffered input batches are represented by `BufferedBatch`.
94+
/// from memory/disk. Buffered input batches are represented by `BufferedBatch`.
9795
///
9896
/// Depending on the type of join, left or right input may be selected as streamed or buffered
9997
/// respectively. For example, in a left-outer join, the left execution plan will be selected as

0 commit comments

Comments
 (0)