This commit is contained in:
Anil Koyuncu
2018-04-04 22:38:14 +02:00
parent 9807eb913c
commit 1b383675cd
2 changed files with 9 additions and 9 deletions
@@ -1,25 +1,26 @@
package edu.lu.uni.serval.FixPatternParser.violations; package edu.lu.uni.serval.FixPatternParser.violations;
import edu.lu.uni.serval.FixPatternParser.Parser; import edu.lu.uni.serval.FixPatternParser.Parser;
import redis.clients.jedis.JedisPool;
import java.io.File; import java.io.File;
public class RunnableCompare implements Runnable { public class RunnableCompare implements Runnable {
private String name; private String name;
private String inputPath; private JedisPool innerPool;
private String innerPort; private JedisPool outerPool;
private Compare comparer; private Compare comparer;
public RunnableCompare(String name , String inputPath, String innerPort, Compare comp) { public RunnableCompare(String name , JedisPool innerPool, JedisPool outerPool, Compare comp) {
this.name = name; this.name = name;
this.inputPath = inputPath; this.innerPool = innerPool;
this.innerPort = innerPort; this.outerPool = outerPool;
this.comparer = comp; this.comparer = comp;
} }
@Override @Override
public void run() { public void run() {
comparer.coreCompare(name, inputPath, innerPort); comparer.coreCompare(name, innerPool, outerPool);
} }
} }
@@ -80,9 +80,8 @@ public class TreeWorker extends UntypedActor {
peek(x -> counter++). peek(x -> counter++).
forEach(m -> forEach(m ->
{ {
Compare compare = new Compare(poolConfig); Compare compare = new Compare();
compare.coreCompare(m, inputPath, innerPort); // compare.coreCompare(m, inputPath, innerPort);
;
} }
); );
} }