alamb commented on code in PR #9080:
URL: https://github.com/apache/arrow-datafusion/pull/9080#discussion_r1479671344
##########
datafusion/physical-plan/src/joins/sort_merge_join.rs:
##########
@@ -610,6 +630,8 @@ struct SMJStream {
pub on_streamed: Vec<PhysicalExprRef>,
/// Join key columns of buffered
pub on_buffered: Vec<PhysicalExprRef>,
+ /// optional join filter
+ pub filter: Option<JoinFilter>,
/// Staging output array builders
pub output_record_batches: Vec<RecordBatch>,
/// Staging output size, including output batches and staging joined
results
Review Comment:
```suggestion
/// Staging output size, including output batches and staging joined
results.
/// Increased when we put rows into buffer and decreased after we
actually output batches.
/// Used to trigger output when sufficient rows are ready
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
