Skip to content

Commit

Permalink
Add comments
Browse files Browse the repository at this point in the history
  • Loading branch information
PointKernel committed Oct 17, 2024
1 parent b205830 commit cc81a07
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 0 deletions.
2 changes: 2 additions & 0 deletions cpp/src/groupby/hash/global_memory_aggregator.cuh
Original file line number Diff line number Diff line change
Expand Up @@ -266,6 +266,8 @@ struct gmem_element_aggregator {
bool* source_mask,
cudf::size_type source_index) const noexcept
{
// Early exit for all aggregation kinds since shared memory aggregation of
// `COUNT_ALL` is always valid
if (!source_mask[source_index]) { return; }

update_target_element_gmem<Source, k>{}(
Expand Down
1 change: 1 addition & 0 deletions cpp/src/groupby/hash/shared_memory_aggregator.cuh
Original file line number Diff line number Diff line change
Expand Up @@ -255,6 +255,7 @@ struct shmem_element_aggregator {
cudf::column_device_view source,
cudf::size_type source_index) const noexcept
{
// Check nullability for all aggregation kinds but `COUNT_ALL`
if constexpr (k != cudf::aggregation::COUNT_ALL) {
if (source.is_null(source_index)) { return; }
}
Expand Down

0 comments on commit cc81a07

Please sign in to comment.