rya-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From miha...@apache.org
Subject [16/51] [partial] incubator-rya git commit: Cannot delete temp branch, doc'd it.
Date Mon, 07 Dec 2015 12:04:46 GMT
http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/5a03ef61/extras/indexing/src/test/java/mvm/rya/indexing/external/AccumuloIndexSetTest.java
----------------------------------------------------------------------
diff --git a/extras/indexing/src/test/java/mvm/rya/indexing/external/AccumuloIndexSetTest.java b/extras/indexing/src/test/java/mvm/rya/indexing/external/AccumuloIndexSetTest.java
deleted file mode 100644
index c8ea57d..0000000
--- a/extras/indexing/src/test/java/mvm/rya/indexing/external/AccumuloIndexSetTest.java
+++ /dev/null
@@ -1,4330 +0,0 @@
-package mvm.rya.indexing.external;
-
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-
-
-import java.util.List;
-import java.util.Set;
-
-import junit.framework.Assert;
-import mvm.rya.indexing.IndexPlanValidator.IndexPlanValidator;
-import mvm.rya.indexing.external.tupleSet.AccumuloIndexSet;
-import mvm.rya.indexing.external.tupleSet.ExternalProcessorTest.ExternalTupleVstor;
-import mvm.rya.indexing.external.tupleSet.ExternalTupleSet;
-
-import org.apache.accumulo.core.client.AccumuloException;
-import org.apache.accumulo.core.client.AccumuloSecurityException;
-import org.apache.accumulo.core.client.Connector;
-import org.apache.accumulo.core.client.MutationsRejectedException;
-import org.apache.accumulo.core.client.TableExistsException;
-import org.apache.accumulo.core.client.TableNotFoundException;
-import org.apache.accumulo.core.client.mock.MockInstance;
-import org.junit.Before;
-import org.junit.Test;
-import org.openrdf.model.URI;
-import org.openrdf.model.impl.LiteralImpl;
-import org.openrdf.model.impl.URIImpl;
-import org.openrdf.model.vocabulary.RDF;
-import org.openrdf.model.vocabulary.RDFS;
-import org.openrdf.query.BindingSet;
-import org.openrdf.query.MalformedQueryException;
-import org.openrdf.query.QueryEvaluationException;
-import org.openrdf.query.QueryLanguage;
-import org.openrdf.query.QueryResultHandlerException;
-import org.openrdf.query.TupleQueryResultHandler;
-import org.openrdf.query.TupleQueryResultHandlerException;
-import org.openrdf.query.algebra.TupleExpr;
-import org.openrdf.query.parser.ParsedQuery;
-import org.openrdf.query.parser.sparql.SPARQLParser;
-import org.openrdf.repository.RepositoryException;
-import org.openrdf.repository.sail.SailRepository;
-import org.openrdf.repository.sail.SailRepositoryConnection;
-import org.openrdf.sail.Sail;
-import org.openrdf.sail.SailException;
-import org.openrdf.sail.memory.MemoryStore;
-
-import com.beust.jcommander.internal.Sets;
-import com.google.common.collect.Lists;
-
-public class AccumuloIndexSetTest {
-
-    private SailRepositoryConnection conn;
-    private Connector accCon;
-    String tablename = "table";
-    Sail s;
-    URI obj,obj2,subclass, subclass2, talksTo;
-   
-    
-    
-    
-    @Before
-    public void init() throws RepositoryException, TupleQueryResultHandlerException, QueryEvaluationException, MalformedQueryException, AccumuloException, AccumuloSecurityException, TableExistsException {
-
-        s = new MemoryStore();
-        SailRepository repo = new SailRepository(s);
-        repo.initialize();
-        conn = repo.getConnection();
-
-        URI sub = new URIImpl("uri:entity");
-        subclass = new URIImpl("uri:class");
-        obj = new URIImpl("uri:obj");
-        talksTo = new URIImpl("uri:talksTo");
-
-        conn.add(sub, RDF.TYPE, subclass);
-        conn.add(sub, RDFS.LABEL, new LiteralImpl("label"));
-        conn.add(sub, talksTo, obj);
-
-        URI sub2 = new URIImpl("uri:entity2");
-        subclass2 = new URIImpl("uri:class2");
-        obj2 = new URIImpl("uri:obj2");
-
-        conn.add(sub2, RDF.TYPE, subclass2);
-        conn.add(sub2, RDFS.LABEL, new LiteralImpl("label2"));
-        conn.add(sub2, talksTo, obj2);
-
-        accCon = new MockInstance().getConnector("root", "".getBytes());
-        accCon.tableOperations().create(tablename);
-        
-
-      
-
-    }
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateSingeIndex() {
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?e ?l ?c " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-
-        
-        CountingResultHandler crh = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais = null; 
-        
-        try {
-            ais = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-//        Scanner scan = null;
-//        try {
-//            scan = accCon.createScanner(tablename, new Authorizations("auths"));
-//        } catch (TableNotFoundException e) {
-//            
-//            e.printStackTrace();
-//        }
-        
-//        scan.setRange(new Range());
-//        
-//        for (Map.Entry<Key, Value> entry : scan) {
-//            System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//            System.out.println("Key is " + entry.getKey());
-//            System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//        }
-        
-        
-        
-        
-        index.add(ais);
-        
-        Assert.assertEquals((double)crh.getCount(), ais.cardinality());
-        
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l . "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "}";//
-
-        
-             
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-      
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-       
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        CountingResultHandler crh2 = new CountingResultHandler();
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(crh1.getCount(), crh2.getCount());
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexTwoVarOrder1() {
-        
-        
-        try {
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?e ?l ?c " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?o ?l " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l . "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-//        Scanner scan = null;
-//        try {
-//            scan = accCon.createScanner(tablename, new Authorizations("auths"));
-//        } catch (TableNotFoundException e) {
-//            
-//            e.printStackTrace();
-//        }
-        
-//        scan.setRange(new Range());
-//        
-//        for (Map.Entry<Key, Value> entry : scan) {
-//            System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//            System.out.println("Key is " + entry.getKey());
-//            System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//        }
-        
-        
-        
-        
-        index.add(ais1);
-        index.add(ais2);
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-  
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-      
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-     
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(2, crh1.getCount());
-        Assert.assertEquals(2, crh2.getCount());
-        
-        
-        
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-   @Test
-    public void testEvaluateTwoIndexTwoVarOrder2() {
-        
-        
-        try {
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?o ?l " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l . "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-      
-        
-        
-        index.add(ais1);
-        index.add(ais2);
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-     
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-        
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-     
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(2, crh1.getCount());
-        Assert.assertEquals(2, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexTwoVarInvalidOrder() {
-        
-        
-        try {
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?e ?c ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?o ?l " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l . "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-
-        
-        
-        index.add(ais1);
-        index.add(ais2);
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-       
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-       
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        } 
-        
-        Assert.assertEquals(crh1.getCount(), crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder1() {
-        
-        
-        
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-       
-
-        try {
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?c ?l ?f ?o" //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-      
-        
-        
-        index.add(ais1);
-        index.add(ais2);
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-    
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-  
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-     
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(2, crh1.getCount());
-        Assert.assertEquals(2, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    //@Test
-    public void testEvaluateTwoIndexThreeVarsDiffLabel() {
-        
-        
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-       
-
-        try {
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?dog ?pig ?owl  " //
-                + "{" //
-                + "  ?pig a ?dog . "//
-                + "  ?pig <http://www.w3.org/2000/01/rdf-schema#label> ?owl "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?c ?l ?f ?o" //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-//        try {
-//            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-//            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-//        } catch (TupleQueryResultHandlerException e2) {
-//            
-//            e2.printStackTrace();
-//        } catch (QueryEvaluationException e2) {
-//            
-//            e2.printStackTrace();
-//        } catch (MalformedQueryException e2) {
-//            
-//            e2.printStackTrace();
-//        } catch (RepositoryException e2) {
-//            
-//            e2.printStackTrace();
-//        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-//        
-//      Scanner scan = null;
-//      try {
-//          scan = accCon.createScanner(tablename, new Authorizations("auths"));
-//      } catch (TableNotFoundException e) {
-//          
-//          e.printStackTrace();
-//      }
-//      
-//      scan.setRange(new Range());
-//      
-//      for (Map.Entry<Key, Value> entry : scan) {
-//          System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//          System.out.println("Key is " + entry.getKey());
-//          System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//      }
-        
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-//        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-//        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-//          
-//  
-//        crh1 = new CountingResultHandler();
-//        crh2 = new CountingResultHandler();
-//        
-//        
-//        try {
-//            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-//        } catch (TupleQueryResultHandlerException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (QueryEvaluationException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (MalformedQueryException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (RepositoryException e1) {
-//            
-//            e1.printStackTrace();
-//        }
-
-        
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-        processor.process(pq.getTupleExpr());
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-     
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-      //  Assert.assertEquals(2, crh1.getCount());
-        Assert.assertEquals(2, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder2() {
-        
-        
-        
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-       
-
-        try {
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?o ?f ?e ?c ?l  " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-//        
-//        try {
-//            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-//        } catch (TupleQueryResultHandlerException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (QueryEvaluationException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (MalformedQueryException e1) {
-//            
-//            e1.printStackTrace();
-//        } catch (RepositoryException e1) {
-//            
-//            e1.printStackTrace();
-//        }
-
-        
-      
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-       
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-     
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
- //       Assert.assertEquals(2, crh1.getCount());
-        Assert.assertEquals(2, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder3ThreeBindingSet() {
-        
-        
-        URI sub3 = new URIImpl("uri:entity3");
-        URI subclass3 = new URIImpl("uri:class3");
-        URI obj3 = new URIImpl("uri:obj3");
-                
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-        URI superclass3 = new URIImpl("uri:superclass3");
-       
-
-        try {
-            
-            conn.add(sub3, RDF.TYPE, subclass3);
-            conn.add(sub3, RDFS.LABEL, new LiteralImpl("label3"));
-            conn.add(sub3, talksTo, obj3);
-            
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(subclass3, RDF.TYPE, superclass3);
-            
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-            conn.add(obj3, RDFS.LABEL, new LiteralImpl("label3"));
-            
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-        
-          
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?o ?f ?l ?e ?c  " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        
-//      Scanner scan1 = null;
-//      Scanner scan2 = null;
-//      try {
-//          scan1 = accCon.createScanner(tablename, new Authorizations("auths"));
-//          scan2 = accCon.createScanner("table2", new Authorizations("auths"));
-//      } catch (TableNotFoundException e) {
-//          
-//          e.printStackTrace();
-//      }
-//      
-//      scan1.setRange(new Range());
-//      
-//      for (Map.Entry<Key, Value> entry : scan1) {
-//          System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//          System.out.println("Key is " + entry.getKey());
-//          System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//      }
-//      
-//      
-//      scan2.setRange(new Range());
-//      
-//      for (Map.Entry<Key, Value> entry : scan2) {
-//          System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//          System.out.println("Key is " + entry.getKey());
-//          System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//      }
-        
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-     
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-        
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        // new SPARQLResultsXMLWriter(System.out)
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(3, crh1.getCount());
-        Assert.assertEquals(3, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder5ThreeBindingSet() {
-        
-        
-        URI sub3 = new URIImpl("uri:entity3");
-        URI subclass3 = new URIImpl("uri:class3");
-        URI obj3 = new URIImpl("uri:obj3");
-                
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-        URI superclass3 = new URIImpl("uri:superclass3");
-       
-
-        try {
-            
-            conn.add(sub3, RDF.TYPE, subclass3);
-            conn.add(sub3, RDFS.LABEL, new LiteralImpl("label3"));
-            conn.add(sub3, talksTo, obj3);
-            
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(subclass3, RDF.TYPE, superclass3);
-            
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-            conn.add(obj3, RDFS.LABEL, new LiteralImpl("label3"));
-            
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-        
-          
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?o ?f ?e ?l ?c  " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-         
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-        
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-       
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        // new SPARQLResultsXMLWriter(System.out)
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(3, crh1.getCount());
-        Assert.assertEquals(3, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder4ThreeBindingSet() {
-        
-        
-        URI sub3 = new URIImpl("uri:entity3");
-        URI subclass3 = new URIImpl("uri:class3");
-        URI obj3 = new URIImpl("uri:obj3");
-                
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-        URI superclass3 = new URIImpl("uri:superclass3");
-       
-
-        try {
-            
-            conn.add(sub3, RDF.TYPE, subclass3);
-            conn.add(sub3, RDFS.LABEL, new LiteralImpl("label3"));
-            conn.add(sub3, talksTo, obj3);
-            
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(subclass3, RDF.TYPE, superclass3);
-            
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-            conn.add(obj3, RDFS.LABEL, new LiteralImpl("label3"));
-            
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-        
-          
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?o ?f ?c ?e ?l  " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        
-//      Scanner scan1 = null;
-//      Scanner scan2 = null;
-//      try {
-//          scan1 = accCon.createScanner(tablename, new Authorizations("auths"));
-//          scan2 = accCon.createScanner("table2", new Authorizations("auths"));
-//      } catch (TableNotFoundException e) {
-//          
-//          e.printStackTrace();
-//      }
-//      
-//      scan1.setRange(new Range());
-//      
-//      for (Map.Entry<Key, Value> entry : scan1) {
-//          System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//          System.out.println("Key is " + entry.getKey());
-//          System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//      }
-//      
-//      
-//      scan2.setRange(new Range());
-//      
-//      for (Map.Entry<Key, Value> entry : scan2) {
-//          System.out.println("Key row string is " + entry.getKey().getRow().toString());
-//          System.out.println("Key is " + entry.getKey());
-//          System.out.println("Value is " + (new String(entry.getKey().getColumnQualifier().toString())));
-//
-//      }
-        
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-        
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-        
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        //new SPARQLResultsXMLWriter(System.out)
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(3, crh1.getCount());
-        Assert.assertEquals(3, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder6ThreeBindingSet() {
-        
-        
-        URI sub3 = new URIImpl("uri:entity3");
-        URI subclass3 = new URIImpl("uri:class3");
-        URI obj3 = new URIImpl("uri:obj3");
-                
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-        URI superclass3 = new URIImpl("uri:superclass3");
-       
-
-        try {
-            
-            conn.add(sub3, RDF.TYPE, subclass3);
-            conn.add(sub3, RDFS.LABEL, new LiteralImpl("label3"));
-            conn.add(sub3, talksTo, obj3);
-            
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(subclass3, RDF.TYPE, superclass3);
-            
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-            conn.add(obj3, RDFS.LABEL, new LiteralImpl("label3"));
-            
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-        
-          
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?c ?l ?e ?o ?f " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-       
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-      
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        //new SPARQLResultsXMLWriter(System.out)
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(3, crh1.getCount());
-        Assert.assertEquals(3, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarOrder7ThreeBindingSet() {
-        
-        
-        URI sub3 = new URIImpl("uri:entity3");
-        URI subclass3 = new URIImpl("uri:class3");
-        URI obj3 = new URIImpl("uri:obj3");
-                
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-        URI superclass3 = new URIImpl("uri:superclass3");
-       
-
-        try {
-            
-            conn.add(sub3, RDF.TYPE, subclass3);
-            conn.add(sub3, RDFS.LABEL, new LiteralImpl("label3"));
-            conn.add(sub3, talksTo, obj3);
-            
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(subclass3, RDF.TYPE, superclass3);
-            
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-            conn.add(obj3, RDFS.LABEL, new LiteralImpl("label3"));
-            
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-        
-          
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?o ?l ?c ?e ?f " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-      
-        
-        index.add(ais2);
-        index.add(ais1);
-        
-        
-        Assert.assertEquals((double)crh1.getCount(), ais1.cardinality());
-        Assert.assertEquals((double)crh2.getCount(), ais2.cardinality());
-          
-  
-        crh1 = new CountingResultHandler();
-        crh2 = new CountingResultHandler();
-        
-        
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh1);
-        } catch (TupleQueryResultHandlerException e1) {
-            
-            e1.printStackTrace();
-        } catch (QueryEvaluationException e1) {
-            
-            e1.printStackTrace();
-        } catch (MalformedQueryException e1) {
-            
-            e1.printStackTrace();
-        } catch (RepositoryException e1) {
-            
-            e1.printStackTrace();
-        }
-
-        
-        
-        
-        ParsedQuery pq = null;
-        SPARQLParser sp = new SPARQLParser();
-        try {
-            pq = sp.parseQuery(queryString, null);
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        }
-       
-        ExternalProcessor processor = new ExternalProcessor(index);
-
-
-        
-        Sail processingSail = new ExternalSail(s, processor);
-        SailRepository smartSailRepo = new SailRepository(processingSail);
-        try {
-            smartSailRepo.initialize();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        //new SPARQLResultsXMLWriter(System.out)
-
-        try {
-            smartSailRepo.getConnection().prepareTupleQuery(QueryLanguage.SPARQL, queryString).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (RepositoryException e) {
-            
-            e.printStackTrace();
-        }
-        
-        Assert.assertEquals(3, crh1.getCount());
-        Assert.assertEquals(3, crh2.getCount());
-         
-        
-        
-    }
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    
-    @Test
-    public void testEvaluateTwoIndexThreeVarInvalidOrder1() {
-        
-        
-        
-        URI superclass = new URIImpl("uri:superclass");
-        URI superclass2 = new URIImpl("uri:superclass2");
-       
-
-        try {
-            conn.add(subclass, RDF.TYPE, superclass);
-            conn.add(subclass2, RDF.TYPE, superclass2);
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e5) {
-            
-            e5.printStackTrace();
-        }
-        
-        
-        try {
-            if(accCon.tableOperations().exists("table2")){
-                accCon.tableOperations().delete("table2");
-            }
-            accCon.tableOperations().create("table2");
-        } catch (AccumuloException e4) {
-            
-            e4.printStackTrace();
-        } catch (AccumuloSecurityException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableExistsException e4) {
-            
-            e4.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-        
-        
-        try {
-            conn.add(obj, RDFS.LABEL, new LiteralImpl("label"));
-            conn.add(obj2, RDFS.LABEL, new LiteralImpl("label2"));
-        } catch (RepositoryException e3) {
-            
-            e3.printStackTrace();
-        }
-       
-        
-        
-        // TODO Auto-generated method stub
-        String indexSparqlString = ""//
-                + "SELECT ?c ?e ?l  " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l "//
-                + "}";//
-        
-        
-        String indexSparqlString2 = ""//
-                + "SELECT ?e ?o ?f ?c ?l  " //
-                + "{" //
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-        
-        
-        String queryString = ""//
-                + "SELECT ?e ?c ?l ?f ?o " //
-                + "{" //
-                + "  ?e a ?c . "//
-                + "  ?e <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?e <uri:talksTo> ?o . "//
-                + "  ?o <http://www.w3.org/2000/01/rdf-schema#label> ?l. "//
-                + "  ?c a ?f . " //
-                + "}";//
-
-        
-        
-        
-        
-
-        
-        CountingResultHandler crh1 = new CountingResultHandler();
-        CountingResultHandler crh2 = new CountingResultHandler();
-        try {
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString).evaluate(crh1);
-            conn.prepareTupleQuery(QueryLanguage.SPARQL, indexSparqlString2).evaluate(crh2);
-        } catch (TupleQueryResultHandlerException e2) {
-            
-            e2.printStackTrace();
-        } catch (QueryEvaluationException e2) {
-            
-            e2.printStackTrace();
-        } catch (MalformedQueryException e2) {
-            
-            e2.printStackTrace();
-        } catch (RepositoryException e2) {
-            
-            e2.printStackTrace();
-        }
-
-       
-
-        List<ExternalTupleSet> index = Lists.newArrayList();
-        AccumuloIndexSet ais1 = null;
-        AccumuloIndexSet ais2 = null;
-                
-        try {
-            ais1 = new AccumuloIndexSet(indexSparqlString, conn, accCon, tablename);
-            ais2 = new AccumuloIndexSet(indexSparqlString2, conn, accCon, "table2");
-        } catch (MalformedQueryException e) {
-            
-            e.printStackTrace();
-        } catch (SailException e) {
-            
-            e.printStackTrace();
-        } catch (QueryEvaluationException e) {
-            
-            e.printStackTrace();
-        } catch (MutationsRejectedException e) {
-            
-            e.printStackTrace();
-        } catch (TableNotFoundException e) {
-            
-            e.printStackTrace();
-        }
-      
-        
-        index.add(ais2

<TRUNCATED>


Mime
View raw message