Skip to content
Merged
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion cpp/src/stream_compaction/distinct.cu
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,12 @@ std::unique_ptr<table> distinct(table_view const& input,
auto counting_iter = thrust::make_counting_iterator<size_type>(0);
rmm::device_uvector<bool> index_exists_in_map(num_rows, stream, mr);
// enumerate all indices to check if they are present in the map.
key_map.contains(counting_iter, counting_iter + num_rows, index_exists_in_map.begin(), hash_key);
key_map.contains(counting_iter,
counting_iter + num_rows,
index_exists_in_map.begin(),
hash_key,
thrust::equal_to<size_type>{},
stream.value());
Comment thread
PointKernel marked this conversation as resolved.
Outdated

auto const output_size{key_map.get_size()};

Expand Down