kNN-IS: An Iterative Spark-based design of the k-Nearest Neighbors classifier for big data.
@JMailloH / (4)
This is an open-source Spark package about an exact k-nearest neighbors classification based on Apache Spark. We take advantage of its in-memory operations to simultaneously classify big amounts of unseen cases against a big training dataset. The map phase computes the k-nearest neighbors in different splits of the training data. Afterwards, multiple reducers process the definitive neighbors from the list obtained in the map phase. The key point of this proposal lies on the management of the test set, maintaining it in memory when it is possible. Otherwise, this is split into a minimum number of pieces, applying a MapReduce per chunk, using the caching skills of Spark to reuse the previously partitioned training set.
Include this package in your Spark Applications using:
spark-shell, pyspark, or spark-submit
> $SPARK_HOME/bin/spark-shell --packages JMailloH:kNN_IS:3.0
If you use the sbt-spark-package plugin, in your sbt build file, add:
spDependencies += "JMailloH/kNN_IS:3.0"
resolvers += "Spark Packages Repo" at "https://repos.spark-packages.org/" libraryDependencies += "JMailloH" % "kNN_IS" % "3.0"
MavenIn your pom.xml, add:
<dependencies> <!-- list of dependencies --> <dependency> <groupId>JMailloH</groupId> <artifactId>kNN_IS</artifactId> <version>3.0</version> </dependency> </dependencies> <repositories> <!-- list of other repositories --> <repository> <id>SparkPackagesRepo</id> <url>https://repos.spark-packages.org/</url> </repository> </repositories>