ding-young commented on code in PR #16616:
URL: https://github.com/apache/datafusion/pull/16616#discussion_r2174042836


##########
datafusion/physical-plan/src/common.rs:
##########
@@ -91,7 +91,7 @@ fn build_file_list_recurse(
 
 /// If running in a tokio context spawns the execution of `stream` to a 
separate task
 /// allowing it to execute in parallel with an intermediate buffer of size 
`buffer`
-pub(crate) fn spawn_buffered(
+pub fn spawn_buffered(

Review Comment:
   I changed the visibility of `spawn_buffered` to pub to use it in the test.
   If this isn't ideal, I'll follow any suggestions. (Perhaps duplicating the 
code might be better?) 



-- 
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

Reply via email to