Skip to content

Commit

Permalink
Rename function
Browse files Browse the repository at this point in the history
  • Loading branch information
ttnghia committed Sep 13, 2023
1 parent 01cc1c2 commit f5a6a1a
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 12 deletions.
20 changes: 10 additions & 10 deletions cpp/src/stream_compaction/distinct.cu
Original file line number Diff line number Diff line change
Expand Up @@ -97,16 +97,16 @@ rmm::device_uvector<size_type> get_distinct_indices(table_view const& input,
}

// For other keep options, reduce by row on rows that compare equal.
auto const reduction_results = indices_reduce_by_row(map,
std::move(preprocessed_input),
input.num_rows(),
has_nulls,
has_nested_columns,
keep,
nulls_equal,
nans_equal,
stream,
rmm::mr::get_current_device_resource());
auto const reduction_results = reduce_by_row(map,
std::move(preprocessed_input),
input.num_rows(),
has_nulls,
has_nested_columns,
keep,
nulls_equal,
nans_equal,
stream,
rmm::mr::get_current_device_resource());

// Extract the desired output indices from reduction results.
auto const map_end = [&] {
Expand Down
2 changes: 1 addition & 1 deletion cpp/src/stream_compaction/distinct_helpers.cu
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ struct reduce_func_builder {
} // namespace

// This function is split from `distinct.cu` to improve compile time.
rmm::device_uvector<size_type> indices_reduce_by_row(
rmm::device_uvector<size_type> reduce_by_row(
hash_map_type const& map,
std::shared_ptr<cudf::experimental::row::equality::preprocessed_table> const preprocessed_input,
size_type num_rows,
Expand Down
2 changes: 1 addition & 1 deletion cpp/src/stream_compaction/distinct_helpers.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ auto constexpr reduction_init_value(duplicate_keep_option keep)
* @param mr Device memory resource used to allocate the returned vector
* @return A device_uvector containing the reduction results
*/
rmm::device_uvector<size_type> indices_reduce_by_row(
rmm::device_uvector<size_type> reduce_by_row(
hash_map_type const& map,
std::shared_ptr<cudf::experimental::row::equality::preprocessed_table> const preprocessed_input,
size_type num_rows,
Expand Down

0 comments on commit f5a6a1a

Please sign in to comment.