code for kmeans based anomaly detection with spark
- Spark
- Packages: Scipy, Numpy, ...
- Data file from 'KDD Cup 1999' http://bit.ly/1ALCuZN
Run with 'spark-submit --master spark://<cluster_ip>:7077 --executor-memory 2GB --driver-memory 2G app_dataframe.py