alamb commented on PR #13223: URL: https://github.com/apache/datafusion/pull/13223#issuecomment-2452562669
> Thanks @alamb that was pretty interesting to read. So this is sort of memory barrier where multiple consumers can hold the resource but its released whenever first consumer send OnceAsync? I think it is more like the shared rendezvous point for all the output streams -- aka to start producing data out of each partition, the left side is read in entirely. The way the output streams wait for the left side to be read is by waiting on the `OnceAsync` -- and once it resolves all the output streams get a (read only) copy of the data to work on -- 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: github-unsubscr...@datafusion.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org For additional commands, e-mail: github-h...@datafusion.apache.org
