alamb commented on code in PR #6507:
URL: https://github.com/apache/arrow-datafusion/pull/6507#discussion_r1212356765
##########
datafusion/core/src/physical_plan/coalesce_partitions.rs:
##########
@@ -137,27 +131,17 @@ impl ExecutionPlan for CoalescePartitionsExec {
// use a stream that allows each sender to put in at
// least one result in an attempt to maximize
// parallelism.
- let (sender, receiver) =
- mpsc::channel::<Result<RecordBatch>>(input_partitions);
+ let mut builder =
Review Comment:
I am quite pleased that this is now all encapsulated into
`RecordBatchReceiverStream`
##########
datafusion/core/src/physical_plan/union.rs:
##########
@@ -560,40 +561,6 @@ impl Stream for CombinedRecordBatchStream {
}
}
-/// Stream wrapper that records `BaselineMetrics` for a particular
Review Comment:
moved
--
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]
