Skip to content

Commit

Permalink
Rename single pass functor + fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
PointKernel committed Oct 15, 2024
1 parent 9261052 commit 0bfcd9f
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 21 deletions.
2 changes: 1 addition & 1 deletion cpp/src/groupby/hash/compute_single_pass_aggs.cu
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@

#include "compute_single_pass_aggs.hpp"
#include "flatten_single_pass_aggs.hpp"
#include "groupby_kernels.cuh"
#include "helpers.cuh"
#include "single_pass_functors.cuh"
#include "var_hash_functor.cuh"

#include <cudf/column/column_factories.hpp>
Expand Down
16 changes: 7 additions & 9 deletions cpp/src/groupby/hash/compute_single_pass_aggs.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -21,20 +21,18 @@
#include <cudf/utilities/span.hpp>

#include <rmm/cuda_stream_view.hpp>
#include <rmm/device_uvector.hpp>

namespace cudf::groupby::detail::hash {
/**
* @brief Computes all aggregations from `requests` that require a single pass
* over the data and stores the results in `sparse_results`
*/
template <typename SetType>
rmm::device_uvector<cudf::size_type> compute_single_pass_aggs(
int64_t num_keys,
bool skip_rows_with_nulls,
bitmask_type const* row_bitmask,
SetType global_set,
cudf::host_span<cudf::groupby::aggregation_request const> requests,
cudf::detail::result_cache* sparse_results,
rmm::cuda_stream_view stream);
void compute_single_pass_aggs(int64_t num_keys,
bool skip_rows_with_nulls,
bitmask_type const* row_bitmask,
SetType set,
cudf::host_span<cudf::groupby::aggregation_request const> requests,
cudf::detail::result_cache* sparse_results,
rmm::cuda_stream_view stream);
} // namespace cudf::groupby::detail::hash
Original file line number Diff line number Diff line change
Expand Up @@ -13,20 +13,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/

#pragma once

#include <cudf/detail/aggregation/aggregation.hpp>
#include <cudf/detail/aggregation/device_aggregators.cuh>
#include <cudf/groupby.hpp>
#include <cudf/utilities/bit.hpp>

#include <thrust/pair.h>
#include <cuco/static_set_ref.cuh>

namespace cudf {
namespace groupby {
namespace detail {
namespace hash {
namespace cudf::groupby::detail::hash {
/**
* @brief Computes single-pass aggregations and store results into a sparse `output_values` table,
* and populate `set` with indices of unique keys
Expand Down Expand Up @@ -102,8 +98,4 @@ struct compute_single_pass_aggs_fn {
}
}
};

} // namespace hash
} // namespace detail
} // namespace groupby
} // namespace cudf
} // namespace cudf::groupby::detail::hash

0 comments on commit 0bfcd9f

Please sign in to comment.