edmondop commented on code in PR #53:
URL: https://github.com/apache/datafusion-ray/pull/53#discussion_r1885182636
##########
src/query_stage.rs:
##########
@@ -99,10 +99,14 @@ impl QueryStage {
/// Get the input partition count. This is the same as the number of
concurrent tasks
/// when we schedule this query stage for execution
pub fn get_input_partition_count(&self) -> usize {
Review Comment:
Can you explain why in the case of a leaf node, the input partition is the
same as the output partition of the plan, while in case of a plan with children
it is the output partitioning of the first child? This is assuming that all
children have the same partition count?
--
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
