Skip to content

Proposed get_output_mr() refactor#6

Open
simoneves wants to merge 5 commits into
simoneves/decimal_pr3from
simoneves/decimal_pr3_refactor_0519
Open

Proposed get_output_mr() refactor#6
simoneves wants to merge 5 commits into
simoneves/decimal_pr3from
simoneves/decimal_pr3_refactor_0519

Conversation

@simoneves
Copy link
Copy Markdown
Owner

No description provided.

@simoneves simoneves requested a review from karthikeyann as a code owner May 19, 2026 22:05
Comment on lines 77 to 87
std::unique_ptr<cudf::column> makeOutputColumn( \
std::vector<cudf::groupby::aggregation_result>& results, \
rmm::cuda_stream_view stream) override { \
rmm::cuda_stream_view stream, \
rmm::device_async_resource_ref mr) override { \
auto col = std::move(results[output_idx].results[0]); \
const auto cudfType = cudf_velox::veloxToCudfDataType(resultType); \
if (col->type() != cudfType) { \
col = cudf::cast(*col, cudfType, stream, get_output_mr()); \
col = cudf::cast(*col, cudfType, stream, mr); \
} \
return col; \
} \
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

old code seems correct.
since the function itself is makeOutputColumn, i supposed, this is called only during output column creation.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants