litvinovg/vitro
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

performance tweak in ABoxRecomputer

Browse source
This commit is contained in:
brianjlowe 2013-11-18 15:28:56 -05:00
parent 56fb7843f3
commit 19f2d14b5f
1 changed files with 28 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

35
webapp/src/edu/cornell/mannlib/vitro/webapp/reasoner/ABoxRecomputer.java
View file

@ -3,6 +3,7 @@
package edu.cornell.mannlib.vitro.webapp.reasoner; package edu.cornell.mannlib.vitro.webapp.reasoner;
import java.io.InputStream; import java.io.InputStream;
import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.HashSet; import java.util.HashSet;
import java.util.Iterator; import java.util.Iterator;
@ -295,14 +296,35 @@ public class ABoxRecomputer {
*/ */
protected Collection<String> getAllIndividualURIs() { protected Collection<String> getAllIndividualURIs() {
String queryString = "SELECT DISTINCT ?s WHERE { GRAPH ?g { ?s a ?type } " + HashSet<String> individualURIs = new HashSet<String>();
" FILTER (!bound(?g) || !regex(str(?g),\"tbox\")) } ORDER BY ?s";
return getIndividualURIs(queryString); List<String> classList = new ArrayList<String>();
tboxModel.enterCriticalSection(Lock.READ);
try {
StmtIterator classIt = tboxModel.listStatements(
(Resource) null, RDF.type, OWL.Class);
while(classIt.hasNext()) {
Statement stmt = classIt.nextStatement();
if(stmt.getSubject().isURIResource()
&& stmt.getSubject().getURI() != null
&& !stmt.getSubject().getURI().isEmpty()) {
classList.add(stmt.getSubject().getURI());
}
}
} finally {
tboxModel.leaveCriticalSection();
}
for (String classURI : classList) {
String queryString = "SELECT ?s WHERE { ?s a <" + classURI + "> } ";
getIndividualURIs(queryString, individualURIs);
}
return individualURIs;
} }
protected Collection<String> getIndividualURIs(String queryString) { protected void getIndividualURIs(String queryString, Set<String> individuals) {
Set<String> individuals = new HashSet<String>();
int batchSize = 50000; int batchSize = 50000;
int offset = 0; int offset = 0;
@ -342,7 +364,6 @@ public class ABoxRecomputer {
offset += batchSize; offset += batchSize;
} }
return individuals;
} }
protected void addedABoxTypeAssertion(Resource individual, Model inferenceModel, HashSet<String> unknownTypes) { protected void addedABoxTypeAssertion(Resource individual, Model inferenceModel, HashSet<String> unknownTypes) {