ParallelNeighbors.jl is a Julia package to perform high-performance exact nearest neighbor searches in high-dimensionsal spaces. Unlike NearestNeighbors.jl, this package solely focuses on massively-parallel brute-force search, which becomes necessary once the data dimensionality becomes large.
Currently, the package is experimental, but it should already be usable for most cases. Things that are not yet supported are distance functions other than Euclidean and SqEuclidean.
The package only supports CUDA.jl at the moment, but support for packages like AMDGPU.jl could be implemented in the future.
It is recommended to use Pkg.jl for installation. Follow the command below to install the latest official release or use ] add ParallelNeighbors in the Julia REPL.
import Pkg;
Pkg.add("ParallelNeighbors")If you would like to modify the package locally, you can use Pkg.develop("ParallelNeighbors") or ] dev ParallelNeighbors in the Julia REPL. This fetches a full clone of the package to ~/.julia/dev/ (the path can be changed by setting the environment variable JULIA_PKG_DEVDIR).
As the name implies, ParallelNeighbors is all about parallelization of your nearest neighbors searches. It provides a simple interface to perform massively-parallel nearest neighbors searches: knn(Xtrain, Xtest, k, batch_size; metric, algorithm). The interface is similar to the one provided by NearestNeighbors.jl, yielding two vectors containing the indices and distances of the nearest neighbors.
using ParallelNeighbors
k = 5; # number of neighbors to search
Xtrain = rand(Float32, 1000, 1000);
Xtest = rand(Float32, 1000, 100);
# using CPU-only in the following example
idxs, dists = knn(Xtrain, Xtest, k)Assuming that you have a CUDA-compatible device available, you would use the package as follows (if Xtrain and Xtest is not already a CuMatrix). Note, that different algorithm are available depending on your requirements.
using CUDA
# copy batches of train and test data to the GPU
idxs, dists = knn(Xtrain, Xtest, k; algorithm=:hybrid_batch_all)
# copy the full train data and batches of the test data to the GPU
idxs, dists = knn(Xtrain, Xtest, k; algorithm=:hybrid_batch_test)
# copy the full train and test data to the GPU
idxs, dists = knn(Xtrain, Xtest, k; algorithm=:full)The difference between the algorithms is:
fullcalculates the full distance matrix, then ranks the nearest neighbors, which is currently the slowest method, but might become useful once better specialized GPU kernels are available. In this case all calculations happen on the same device (CPU or GPU).hybrid_batch_testcalculates the distance matrix for a batch of test points to all train points, and sorts the batch (n - 1) in parallel (CPU) while the distance for batch n is calculated (GPU).hybrid_batch_allis the most versatile function, batching distance calculation for the train and test points (GPU), again sorting in parallel (CPU).
The default algorithm is hybrid_batch_all with a default batch size of max(trunc(Int, n^(1 / sqrt(2))), k) and should be the method of choice for most use cases. You can tune the batch_size argument such that it perfectly fits your use case. You should always try to fit all the data on the GPU beforehand as in the following example (reusing the data from above example).
using BenchmarkTools: @benchmark
batch_size = 500
Xtrain_cu, Xtest_cu = cu(Xtrain), cu(Xtest)
# with data copied to the GPU beforehand (fastest)
@benchmark knn($Xtrain_cu, $Xtest_cu, $k, $batch_size)ParallelNeighbors.jl is a community effort and your help is extremely welcome! Please open an issue or pull request if you find a bug or would like to contribute to the project.