This commit is contained in:
Anil Koyuncu
2018-04-04 11:38:10 +02:00
parent 8aedc4ec40
commit 01a5206f3f
@@ -80,56 +80,58 @@ public class AkkaTreeLoader {
String inputPath; String inputPath;
String outputPath; // String outputPath;
String port; String port;
String portInner; String portInner;
String pairsCSVPath; // String pairsCSVPath;
String importScript; String importScript;
String pairsCompletedPath; // String pairsCompletedPath;
String serverWait; String serverWait;
String option; // String option;
String dbDir; String dbDir;
String chunkName; String chunkName;
String numOfWorkers; String numOfWorkers;
if (args.length > 0) { if (args.length > 0) {
inputPath = args[0]; inputPath = args[0];
port = args[1]; // port = args[1];
portInner = args[2]; portInner = args[1];
serverWait = args[3]; serverWait = args[2];
option = args[4]; // option = args[4];
chunkName = args[5]; chunkName = args[3];
dbDir = args[6]; numOfWorkers = args[4];
numOfWorkers = args[7]; dbDir = args[5];
// pairsCSVPath = args[3]; // pairsCSVPath = args[3];
// importScript = args[4]; // importScript = args[4];
// pairsCompletedPath = args[3]; // pairsCompletedPath = args[3];
} else { } else {
inputPath = "/Users/anilkoyuncu/bugStudy/dataset/GumTreeOutput2"; inputPath = "/Users/anilkoyuncu/bugStudy/dataset/GumTreeOutput2";
outputPath = "/Users/anilkoyuncu/bugStudy/dataset/"; // outputPath = "/Users/anilkoyuncu/bugStudy/dataset/";
port = "6379"; // port = "6379";
portInner = "6380"; portInner = "6380";
serverWait = "10000"; serverWait = "10000";
option = "COMP"; // option = "COMP";
pairsCSVPath = "/Users/anilkoyuncu/bugStudy/dataset/pairs/test"; // pairsCSVPath = "/Users/anilkoyuncu/bugStudy/dataset/pairs/test";
importScript = "/Users/anilkoyuncu/bugStudy/dataset/pairs/test2.sh"; // importScript = "/Users/anilkoyuncu/bugStudy/dataset/pairs/test2.sh";
pairsCompletedPath = "/Users/anilkoyuncu/bugStudy/dataset/pairs_completed"; // pairsCompletedPath = "/Users/anilkoyuncu/bugStudy/dataset/pairs_completed";
chunkName ="chunk5.rdb"; chunkName ="chunk5.rdb";
dbDir = "/Users/anilkoyuncu/bugStudy/dataset/redis"; dbDir = "/Users/anilkoyuncu/bugStudy/dataset/redis";
numOfWorkers = "16"; numOfWorkers = "16";
} }
String parameters = String.format("\nInput path %s \nportInner %s \nserverWait %s \nchunkName %s \nnumOfWorks %s \ndbDir %s",inputPath,portInner,serverWait,chunkName,numOfWorkers,dbDir);
log.info(parameters);
if (option.equals("CALC")) { // if (option.equals("CALC")) {
calculatePairs(inputPath, port); // calculatePairs(inputPath, port);
log.info("Calculate pairs done"); // log.info("Calculate pairs done");
}else { // }else {
comparePairs(port, inputPath, portInner, serverWait,chunkName,dbDir,numOfWorkers); comparePairs(inputPath, portInner, serverWait,chunkName,dbDir,numOfWorkers);
} // }
} }
public static void comparePairs(String port,String inputPath, String innerPort,String serverWait,String chunkName, String dbDir,String numOfWorkers){ public static void comparePairs(String inputPath, String innerPort,String serverWait,String chunkName, String dbDir,String numOfWorkers){
// String cmd; // String cmd;
// cmd = "bash " + importScript +" %s"; // cmd = "bash " + importScript +" %s";