This commit is contained in:
Anil Koyuncu
2018-04-04 16:51:42 +02:00
parent c6d0ce9ab0
commit 11607ca2b3
@@ -93,20 +93,20 @@ public class AkkaTreeLoader {
String numOfWorkers; String numOfWorkers;
if (args.length > 0) { if (args.length > 0) {
inputPath = args[0]; inputPath = args[0];
// port = args[1];
portInner = args[1]; portInner = args[1];
serverWait = args[2]; serverWait = args[2];
// option = args[4]; // option = args[4];
chunkName = args[3]; chunkName = args[3];
numOfWorkers = args[4]; numOfWorkers = args[4];
dbDir = args[5]; dbDir = args[5];
port = args[6];
// 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 = "6399";
portInner = "6380"; portInner = "6380";
serverWait = "10000"; serverWait = "10000";
// option = "COMP"; // option = "COMP";
@@ -116,6 +116,7 @@ public class AkkaTreeLoader {
chunkName ="chunk5.rdb"; chunkName ="chunk5.rdb";
dbDir = "/Users/anilkoyuncu/bugStudy/dataset/redis"; dbDir = "/Users/anilkoyuncu/bugStudy/dataset/redis";
numOfWorkers = "1"; numOfWorkers = "1";
} }
String parameters = String.format("\nInput path %s \nportInner %s \nserverWait %s \nchunkName %s \nnumOfWorks %s \ndbDir %s",inputPath,portInner,serverWait,chunkName,numOfWorkers,dbDir); 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); log.info(parameters);
@@ -124,6 +125,10 @@ public class AkkaTreeLoader {
// calculatePairs(inputPath, port); // calculatePairs(inputPath, port);
// log.info("Calculate pairs done"); // log.info("Calculate pairs done");
// }else { // }else {
String cmd = "bash "+dbDir + "/" + "startServer.sh" +" %s %s %s";
cmd = String.format(cmd, dbDir,"dumps.rdb",Integer.valueOf(port));
loadRedis(cmd,serverWait);
comparePairs(inputPath, portInner, serverWait,chunkName,dbDir,numOfWorkers); comparePairs(inputPath, portInner, serverWait,chunkName,dbDir,numOfWorkers);
// } // }