From 2408eb159ef3c7e1ba275692f6a4636a9876b07c Mon Sep 17 00:00:00 2001 From: fixminer Date: Thu, 13 Sep 2018 16:23:17 +0200 Subject: [PATCH] fix pair record problem in import --- .../uni/serval/fixminer/cluster/CalculatePairs.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/java/edu/lu/uni/serval/fixminer/cluster/CalculatePairs.java b/src/main/java/edu/lu/uni/serval/fixminer/cluster/CalculatePairs.java index 2e25b25..0c91b73 100644 --- a/src/main/java/edu/lu/uni/serval/fixminer/cluster/CalculatePairs.java +++ b/src/main/java/edu/lu/uni/serval/fixminer/cluster/CalculatePairs.java @@ -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(); if(wrBuf.remaining() > 500) { wrBuf.put(buf); @@ -125,10 +126,10 @@ public class CalculatePairs { e.printStackTrace(); } - String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s"; - String stopServer2 = String.format(stopServer,Integer.valueOf(port)); -// loadRedis(stopServer2,serverWait); - cs.runShell(stopServer2,serverWait); +// String stopServer = "bash "+dbDir + "/" + "stopServer.sh" +" %s"; +// String stopServer2 = String.format(stopServer,Integer.valueOf(port)); +//// loadRedis(stopServer2,serverWait); +// cs.runShell(stopServer2,serverWait); log.info("Done pairs"); }