azalea/fixminer_source
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix pair record problem in import

Browse Source
This commit is contained in:
fixminer
2018-09-13 16:23:17 +02:00
parent 0d391e1ab9
commit 2408eb159e
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/fixminer/cluster/CalculatePairs.java
+6 -5
View File
@@ -97,7 +97,8 @@ public class CalculatePairs {
line = String.valueOf(i) +"\t" + String.valueOf(j)+"\n"; // + "\t" + result.get(i) + "\t" + result.get(j)+"\n"; // line = String.valueOf(i) +"\t" + String.valueOf(j)+"\n"; // + "\t" + result.get(i) + "\t" + result.get(j)+"\n";
line = String.valueOf(i) +"," + String.valueOf(j)+"\n"; // + "," + result.get(i) + "," + result.get(j)+"\n";
buf = line.getBytes(); buf = line.getBytes();
if(wrBuf.remaining() > 500) { if(wrBuf.remaining() > 500) {
wrBuf.put(buf); wrBuf.put(buf);
@@ -125,10 +126,10 @@ public class CalculatePairs {
e.printStackTrace(); e.printStackTrace();
} }
String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s"; // String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s";
String stopServer2 = String.format(stopServer,Integer.valueOf(port)); // String stopServer2 = String.format(stopServer,Integer.valueOf(port));
// loadRedis(stopServer2,serverWait); //// loadRedis(stopServer2,serverWait);
cs.runShell(stopServer2,serverWait); // cs.runShell(stopServer2,serverWait);
log.info("Done pairs"); log.info("Done pairs");
} }