xavlee opened a new pull request, #24737: URL: https://github.com/apache/datafusion/pull/24737
## Which issue does this PR relate to? - Part of #24438. ## Rationale for this change A source can concatenate sorted logical runs into one DataFusion output partition. The resulting stream can be globally unsorted while every distinct `(key, time_bin)` grouping tuple still occupies one contiguous range. This fixture records how aggregate execution handles that layout today. ## What changes are included in this PR? - Add a one-partition test source that yields one batch and then remains pending. - Concatenate two sorted logical runs whose `(key, time_bin)` order resets between runs. - Group by the complete `(key, time_bin)` tuple. - Assert `InputOrderMode::Linear`, `EmissionType::Final`, the ordinary single-hash stream, and pending output before EOF. ## Are these changes tested? Yes. The new `group_contiguous_linear_aggregate_waits_for_input_end` test passes as part of: - `cargo test -p datafusion-physical-plan --lib` - workspace-wide clippy with all targets, all features, and warnings denied - the extended workspace test suite with the CI profile and feature set ## Are there any user-facing changes? This PR adds test coverage for existing aggregate behavior. -- 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]
