package main;

import clustering.SparkDBSCAN;

import configuration.SparkFactory;

import org.apache.spark.SparkConf;

import org.apache.spark.api.java.JavaSparkContext;

/**

* Created by wlucia on 29/09/15.

*/

public class SparkDBSCANMain {

public static void main(String[] args) {

if(args.length != 4) {

System.out.println("Bad Parameters :'(");

System.out.println("Usage: java -jar DistributedDbScan epsilon minPts inputFilePath outputFilePath");

System.exit(-1);

}

double epsilon = Double.parseDouble(args[0]);

int minPts = Integer.parseInt(args[1]);

String inputPath = args[2];

String outputPath = args[3];

System.out.println(String.format("*** PARAMS:\nEpsilon -> %f\nMinPts -> %d\nInput -> %s\nOutput -> %s",

epsilon,

minPts,

inputPath,

outputPath

));

JavaSparkContext jsc = new SparkFactory()

.setMaster("local[4]")

.sparkContext("Spark DBSCAN");

SparkDBSCAN dbScan = new SparkDBSCAN(jsc, epsilon, minPts, inputPath, outputPath);

dbScan.clustering();

jsc.close();

}

}