Skip to content

Commit 684c8dd

Browse files
committed
Update comment.
1 parent 1a70073 commit 684c8dd

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

  • datafusion/physical-plan/src/joins/semi_anti_sort_merge_join

datafusion/physical-plan/src/joins/semi_anti_sort_merge_join/stream.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,8 +249,11 @@ pub(crate) struct SemiAntiSortMergeJoinStream {
249249
/// true for semi (emit matched), false for anti (emit unmatched)
250250
is_semi: bool,
251251

252-
// Input streams — "outer" is the streamed side whose rows we output,
253-
// "inner" is the buffered side we match against.
252+
// Input streams — in the nested-loop model that sort-merge join
253+
// implements, "outer" is the driving loop and "inner" is probed for
254+
// matches. The existing SortMergeJoinStream calls these "streamed"
255+
// and "buffered" respectively. For Left* joins, outer=left; for
256+
// Right* joins, outer=right. Output schema equals the outer side.
254257
outer: SendableRecordBatchStream,
255258
inner: SendableRecordBatchStream,
256259

0 commit comments

Comments
 (0)