This commit is contained in:
ANIL KOYUNCU
2020-01-19 17:03:19 +01:00
parent d439bbe8a2
commit ae5e381d4e
2 changed files with 11 additions and 11 deletions
@@ -22,11 +22,11 @@ public class Launcher {
Properties appProps = new Properties(); Properties appProps = new Properties();
// String appConfigPath = "/Users/anilkoyuncu/projects/fixminer/fixminer_source/src/main/resource/app.properties"; String appConfigPath = "/Users/anil.koyuncu/projects/fixminer/fixminer_source/src/main/resource/app.properties";
String appConfigPath = args[0]; // String appConfigPath = args[0];
appProps.load(new FileInputStream(appConfigPath)); appProps.load(new FileInputStream(appConfigPath));
String portInner = appProps.getProperty("portInner","6380"); // String portInner = appProps.getProperty("portInner","6380");
String numOfWorkers = appProps.getProperty("numOfWorkers", "10"); String numOfWorkers = appProps.getProperty("numOfWorkers", "10");
String portDumps = appProps.getProperty("portDumps","6399"); String portDumps = appProps.getProperty("portDumps","6399");
String pjName = appProps.getProperty("pjName","allDataset"); String pjName = appProps.getProperty("pjName","allDataset");
@@ -38,12 +38,12 @@ public class Launcher {
String redisPath = appProps.getProperty("redisPath","FORKJOIN"); String redisPath = appProps.getProperty("redisPath","FORKJOIN");
String srcMLPath = appProps.getProperty("srcMLPath","FORKJOIN"); String srcMLPath = appProps.getProperty("srcMLPath","FORKJOIN");
String parameter = args[2]; // String parameter = args[2];
// String parameter = null; // String parameter = null;
// String parameter = "if"; // String parameter = "if";
// String parameter = "L1"; String parameter = "add";
String jobType = args[1]; // String jobType = args[1];
// String jobType = "RICHEDITSCRIPT"; String jobType = "RICHEDITSCRIPT";
// String jobType = "LOAD"; // String jobType = "LOAD";
// String jobType = "COMPARE"; // String jobType = "COMPARE";
@@ -56,12 +56,12 @@ public class Launcher {
// //
// log.info(parameters); // log.info(parameters);
mainLaunch(portInner, numOfWorkers, jobType, portDumps, pjName,actionType,eDiffTimeout,parallelism,input,redisPath,parameter, srcMLPath); mainLaunch( numOfWorkers, jobType, portDumps, pjName,actionType,eDiffTimeout,parallelism,input,redisPath,parameter, srcMLPath);
} }
public static void mainLaunch(String portInner, String numOfWorkers, String jobType, String portDumps, String pjName, String actionType, String eDiffTimeout, String parallelism,String input, String redisPath,String parameter,String srcMLPath){ public static void mainLaunch(String numOfWorkers, String jobType, String portDumps, String pjName, String actionType, String eDiffTimeout, String parallelism,String input, String redisPath,String parameter,String srcMLPath){
String dbDir; String dbDir;
@@ -106,7 +106,7 @@ public class Launcher {
} }
CompareTrees.main(redisPath, portInner,portDumps,actionType+dumpsName,compareDBName, job); CompareTrees.main(redisPath, portDumps,actionType+dumpsName, job);
break; break;
case "PATTERN": case "PATTERN":
ClusterToPattern.main(portDumps,redisPath, actionType+dumpsName, parameter); ClusterToPattern.main(portDumps,redisPath, actionType+dumpsName, parameter);
@@ -25,7 +25,7 @@ public class CompareTrees {
private static Logger log = LoggerFactory.getLogger(CompareTrees.class); private static Logger log = LoggerFactory.getLogger(CompareTrees.class);
public static void main(String redisPath, String portInner, String portDumps, String dumpsName, String compareDBName, String job) throws Exception { public static void main(String redisPath, String portDumps, String dumpsName, String job) throws Exception {
// shape /Users/anil.koyuncu/projects/test/fixminer-core/python/data/redis ALLdumps-gumInput.rdb clusterl0-gumInputALL.rdb /Users/anil.koyuncu/projects/test/fixminer-core/python/data/richEditScript // shape /Users/anil.koyuncu/projects/test/fixminer-core/python/data/redis ALLdumps-gumInput.rdb clusterl0-gumInputALL.rdb /Users/anil.koyuncu/projects/test/fixminer-core/python/data/richEditScript