Dandandan commented on PR #21240:
URL: https://github.com/apache/datafusion/pull/21240#issuecomment-4171786797
```
let stream = self.right.execute(partition, Arc::clone(&context))?;
// ...
let left_fut = self.left_fut.try_once(|| {
let left_stream = self.left.execute(0, context)?;
Ok(load_left_input(
left_stream,
join_metrics.clone(),
reservation,
))
})?;
Ok(Box::pin(CrossJoinStream {...}))
```
In principle `self.right.execute` only builds the stream - it shouldn't do
any "actual" work, only the setup.
The `CrossJoinStream will drive the execution of the stream (and only can do
so when the left side is loaded.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
