http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/81b99327/extras/indexing/src/test/java/org/apache/rya/accumulo/documentIndex/DocumentIndexIntersectingIteratorTest.java ---------------------------------------------------------------------- diff --git a/extras/indexing/src/test/java/org/apache/rya/accumulo/documentIndex/DocumentIndexIntersectingIteratorTest.java b/extras/indexing/src/test/java/org/apache/rya/accumulo/documentIndex/DocumentIndexIntersectingIteratorTest.java index a237118..7108ae6 100644 --- a/extras/indexing/src/test/java/org/apache/rya/accumulo/documentIndex/DocumentIndexIntersectingIteratorTest.java +++ b/extras/indexing/src/test/java/org/apache/rya/accumulo/documentIndex/DocumentIndexIntersectingIteratorTest.java @@ -23,18 +23,6 @@ import java.util.Collection; import java.util.List; import java.util.Map; -import junit.framework.Assert; -import org.apache.rya.accumulo.AccumuloRdfConfiguration; -import org.apache.rya.accumulo.RyaTableMutationsFactory; -import org.apache.rya.api.domain.RyaStatement; -import org.apache.rya.api.domain.RyaType; -import org.apache.rya.api.domain.RyaURI; -import org.apache.rya.api.resolver.RdfToRyaConversions; -import org.apache.rya.api.resolver.RyaContext; -import org.apache.rya.api.resolver.RyaToRdfConversions; -import org.apache.rya.api.resolver.RyaTripleContext; -import org.apache.rya.indexing.accumulo.entity.EntityCentricIndex; - import org.apache.accumulo.core.client.AccumuloException; import org.apache.accumulo.core.client.AccumuloSecurityException; import org.apache.accumulo.core.client.BatchWriter; @@ -49,29 +37,40 @@ import org.apache.accumulo.core.data.Range; import org.apache.accumulo.core.data.Value; import org.apache.accumulo.core.security.Authorizations; import org.apache.hadoop.io.Text; +import org.apache.rya.accumulo.AccumuloRdfConfiguration; +import org.apache.rya.accumulo.RyaTableMutationsFactory; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.resolver.RdfToRyaConversions; +import org.apache.rya.api.resolver.RyaContext; +import org.apache.rya.api.resolver.RyaToRdfConversions; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.indexing.accumulo.entity.EntityCentricIndex; +import org.eclipse.rdf4j.model.vocabulary.XMLSchema; +import org.eclipse.rdf4j.query.MalformedQueryException; +import org.eclipse.rdf4j.query.QueryEvaluationException; +import org.eclipse.rdf4j.query.TupleQueryResultHandlerException; +import org.eclipse.rdf4j.query.algebra.StatementPattern; +import org.eclipse.rdf4j.query.algebra.TupleExpr; +import org.eclipse.rdf4j.query.algebra.helpers.StatementPatternCollector; +import org.eclipse.rdf4j.query.parser.ParsedQuery; +import org.eclipse.rdf4j.query.parser.sparql.SPARQLParser; +import org.eclipse.rdf4j.repository.RepositoryException; +import org.junit.Assert; import org.junit.Before; import org.junit.Test; -import org.openrdf.model.vocabulary.XMLSchema; -import org.openrdf.query.MalformedQueryException; -import org.openrdf.query.QueryEvaluationException; -import org.openrdf.query.TupleQueryResultHandlerException; -import org.openrdf.query.algebra.StatementPattern; -import org.openrdf.query.algebra.TupleExpr; -import org.openrdf.query.algebra.helpers.StatementPatternCollector; -import org.openrdf.query.parser.ParsedQuery; -import org.openrdf.query.parser.sparql.SPARQLParser; -import org.openrdf.repository.RepositoryException; import com.google.common.primitives.Bytes; public class DocumentIndexIntersectingIteratorTest { - - + + private Connector accCon; String tablename = "table"; - + @Before public void init() throws RepositoryException, TupleQueryResultHandlerException, QueryEvaluationException, @@ -81,1813 +80,1809 @@ public class DocumentIndexIntersectingIteratorTest { accCon.tableOperations().create(tablename); } - - - - - - - -@Test + + @Test public void testBasicColumnObj() throws Exception { BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - m.put(new Text("cf"), new Text(null + "\u0000" + "obj" + "\u0000" + "cq"), new Value(new byte[0])); - m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); + Mutation m = new Mutation(new Text("" + i)); + m.put(new Text("cf"), new Text(null + "\u0000" + "obj" + "\u0000" + "cq"), new Value(new byte[0])); + m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); - if (i == 30 || i == 60) { - m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ"), new Value(new byte[0])); - } + if (i == 30 || i == 60) { + m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ"), new Value(new byte[0])); + } - bw.addMutation(m); + bw.addMutation(m); - } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" )); - TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ" )); - TextColumn tc3 = new TextColumn(new Text("CF"), new Text("obj" + "\u0000" + "CQ" )); + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" )); + TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ" )); + TextColumn tc3 = new TextColumn(new Text("CF"), new Text("obj" + "\u0000" + "CQ" )); - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - dii.setColumnFamilies(is, tc); + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 1****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(2, results); - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - int results = 0; - System.out.println("************************Test 1****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(2, results); - - } - - - - - - - -@Test + + + + + + + + @Test public void testBasicColumnObjPrefix() throws Exception { BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" ), new Value(new byte[0])); + m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); - for (int i = 0; i < 100; i++) { + if (i == 30 || i == 60) { + m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ" ), new Value(new byte[0])); + } - Mutation m = new Mutation(new Text("" + i)); - m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" ), new Value(new byte[0])); - m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); - if (i == 30 || i == 60) { - m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ" ), new Value(new byte[0])); - } - - - bw.addMutation(m); + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq")); + TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ")); + TextColumn tc3 = new TextColumn(new Text("CF"), new Text("obj")); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + tc3.setIsPrefix(true); + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 2****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(2, results); + - } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq")); - TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ")); - TextColumn tc3 = new TextColumn(new Text("CF"), new Text("obj")); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - tc3.setIsPrefix(true); - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 2****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(2, results); - - } - - - - -@Test - public void testBasicColumnSubjObjPrefix() throws Exception { - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq"), new Value(new byte[0])); - m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); + @Test + public void testBasicColumnSubjObjPrefix() throws Exception { - if (i == 30 ) { - m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ"), new Value(new byte[0])); - } - - if (i == 60) { - m.put(new Text("CF"), new Text(null + "\u0000" +"subj" + "\u0000" + "CQ"), new Value(new byte[0])); - } - - - + BatchWriter bw = null; - bw.addMutation(m); + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq"), new Value(new byte[0])); + m.put(new Text("cF"), new Text(null + "\u0000" +"obj" + "\u0000" + "cQ"), new Value(new byte[0])); + if (i == 30 ) { + m.put(new Text("CF"), new Text(null + "\u0000" +"obj" + "\u0000" + "CQ"), new Value(new byte[0])); } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" )); - TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ")); - TextColumn tc3 = new TextColumn(new Text("CF"), new Text("subj")); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - tc3.setIsPrefix(true); - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 3****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; + + if (i == 60) { + m.put(new Text("CF"), new Text(null + "\u0000" +"subj" + "\u0000" + "CQ"), new Value(new byte[0])); } - - - Assert.assertEquals(1, results); - - + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" )); + TextColumn tc2 = new TextColumn(new Text("cF"), new Text("obj" + "\u0000" + "cQ")); + TextColumn tc3 = new TextColumn(new Text("CF"), new Text("subj")); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + tc3.setIsPrefix(true); + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 3****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(1, results); + + + } - - - - -@Test + + + + + @Test public void testOneHundredColumnSubjObj() throws Exception { BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); - } - - if (i == 30 ) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 100), new Value(new byte[0])); - } - - if (i == 60) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 100), new Value(new byte[0])); - } - - - + Mutation m = new Mutation(new Text("" + i)); - bw.addMutation(m); + for(int j= 0; j < 100; j++) { + m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); + } + + if (i == 30 ) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 100), new Value(new byte[0])); + } + if (i == 60) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 100), new Value(new byte[0])); } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); - TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj" + "\u0000" + "cq" + 100)); - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - dii.setColumnFamilies(is, tc); - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); + TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj" + "\u0000" + "cq" + 100)); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 4****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(1, results); + - int results = 0; - System.out.println("************************Test 4****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(1, results); - - } - - - - -@Test + + + + + @Test public void testOneHundredColumnObjPrefix() throws Exception { BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - for (int i = 0; i < 100; i++) { + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j ), new Value(new byte[0])); - } - - if (i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); - } - - - - - + for (int i = 0; i < 100; i++) { - bw.addMutation(m); + Mutation m = new Mutation(new Text("" + i)); + for(int j= 0; j < 100; j++) { + m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j ), new Value(new byte[0])); } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); - TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj")); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - tc3.setIsPrefix(true); - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 5****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; + + if (i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); } - - - Assert.assertEquals(4, results); - - + + + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); + TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj")); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + tc3.setIsPrefix(true); + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 5****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(4, results); + + + } - - - - - - - -@Test + + + + + + + + @Test public void testOneHundredColumnMultipleEntriesPerSubject() throws Exception { BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + for(int j= 0; j < 100; j++) { + m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j ), new Value(new byte[0])); + } + + if (i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); + } + + + + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20 )); + TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 6****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(8, results); + + + + + } + + + + + + @Test + public void testOneHundredColumnSubjObjPrefix() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + for(int j= 0; j < 100; j++) { + m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); + } + + if (i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); + } + + + + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); + TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("subj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 7****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(4, results); + + + + + } + + + + + + + @Test + public void testOneHundredColumnSubjObjPrefixFourTerms() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + for(int j= 0; j < 100; j++) { + m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); + } + + if (i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); + m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); + } + + + + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); + TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("subj")); + TextColumn tc4 = new TextColumn(new Text("cf" + 100), new Text("obj")); + + tc3.setIsPrefix(true); + tc4.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[4]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + tc[3] = tc4; + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 8****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(4, results); + + + + + } + + + + + + + //@Test + public void testOneHundredColumnSameCf() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + for(int j= 0; j < 100; j++) { + m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); + } + + + + bw.addMutation(m); + + } + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" ), new Text("obj" + "\u0000" + "cq" + 20)); + TextColumn tc2 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" + 50)); + TextColumn tc3 = new TextColumn(new Text("cf" ), new Text("obj" + "\u0000" + "cq" + 80)); + TextColumn tc4 = new TextColumn(new Text("cf"), new Text("obj")); + + tc4.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[4]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + tc[3] = tc4; + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 9****************************"); + for (Map.Entry<Key, Value> e : scan) { + //System.out.println(e); + results++; + } + + + Assert.assertEquals(10000, results); + + + + + } + + + + + + @Test + public void testGeneralStarQuery() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + + + + if(i == 30 || i == 60 ) { + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + } + + bw.addMutation(m); + + } + + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3)); + + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 10****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(2, results); + + + + + } + + + + + + + + @Test + public void testGeneralStarQuerySubjPrefix() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + } + + bw.addMutation(m); + + } + + + DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + dii.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 11****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(4, results); + + + + + } + + + + + + @Test + public void testGeneralStarQueryMultipleSubjPrefix() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + } + + bw.addMutation(m); + + } + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 12****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(12, results); + + + + + } + + + + + @Test + public void testFixedRangeColumnValidateExact() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + } + + bw.addMutation(m); + + } + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3)); + TextColumn tc4 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 4)); + TextColumn tc5 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 5)); + + + + TextColumn[] tc = new TextColumn[5]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + tc[3] = tc4; + tc[4] = tc5; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.setRange(Range.exact(new Text("" + 30))); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 14****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(1, results); + + + + + } + + + + + + + @Test + public void testLubmLikeTest() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m1 = new Mutation(new Text("ProfessorA" + i)); + Mutation m2= new Mutation(new Text("ProfessorB" + i)); + + m1.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom";), + new Text(null + "\u0000" +"object" + "\u0000" + "http://www.University"; + i + ".edu"), new Value(new byte[0])); + m2.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom";), + new Text(null + "\u0000" +"object" + "\u0000" + "http://www.University"; + i + ".edu"), new Value(new byte[0])); + m1.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), + new Text(null + "\u0000" +"object" + "\u0000" + "http://Course"; + i), new Value(new byte[0])); + m2.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), + new Text(null + "\u0000" +"object" + "\u0000" + "http://Course"; + i), new Value(new byte[0])); + + + bw.addMutation(m1); + bw.addMutation(m2); + + } + + + + TextColumn tc1 = new TextColumn(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom"; ), + new Text("object" + "\u0000" + "http://www.University"; + 30 + ".edu")); + TextColumn tc2 = new TextColumn(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), + new Text("object" + "\u0000" + "http://Course"; + 30)); + + + + + TextColumn[] tc = new TextColumn[2]; + tc[0] = tc1; + tc[1] = tc2; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 15****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(2, results); + + + + + } + + + + + + + + + + + + + + + + + + @Test + public void testFixedRangeColumnValidateSubjPrefix() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); + } + + bw.addMutation(m); + + } + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.setRange(Range.exact(new Text("" + 30))); + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 13****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(3, results); + + + + + } + + + + + + //@Test + //public void testRangeBound() { + // + // BatchWriter bw = null; + // + // try { + // + // + // + // + // for (int i = 0; i < 100; i++) { + // + // Mutation m = new Mutation(new Text("" + i)); + // + // m.put(new Text("cf" + 1), new Text("obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + // m.put(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + // m.put(new Text("cf" + 1), new Text("subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + // m.put(new Text("cf" + 2), new Text("subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + // + // + // + // if(i == 30 || i == 60 || i == 90 || i == 99) { + // m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + // m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + // m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + // m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); + // m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + // m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); + // } + // + // bw.addMutation(m); + // + // } + // + // + // + // Text cf = new Text("cf" + 3); + // Text cq = new Text("obj" + "\u0000" + "cq" + 3); + // + // Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + // scan.fetchColumn(cf, cq ); + // scan.setRange(new Range()); + // + // + // int results = 0; + // System.out.println("************************Test 14****************************"); + // for (Map.Entry<Key, Value> e : scan) { + // System.out.println(e); + // results++; + // } + // + // + // + // + // + // + // } catch (MutationsRejectedException e) { + // // TODO Auto-generated catch block + // e.printStackTrace(); + // } catch (TableNotFoundException e) { + // // TODO Auto-generated catch block + // e.printStackTrace(); + // } + // + //} + + + + + + @Test + public void testContext1() throws Exception { + + BatchWriter bw = null; + + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + + + for (int i = 0; i < 100; i++) { + + Mutation m = new Mutation(new Text("" + i)); + + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 4 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); + + } + + bw.addMutation(m); + + } + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("obj")); + + tc3.setIsPrefix(true); + + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; + + + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setContext(is, "context1"); + + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + + scan.addScanIterator(is); + + int results = 0; + System.out.println("************************Test 14****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } + + + Assert.assertEquals(8, results); + + + + + } - for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j ), new Value(new byte[0])); - } - - if (i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); - } - - - - - - bw.addMutation(m); - } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20 )); - TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("obj")); - - tc3.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 6****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(8, results); - - - } - - - - -@Test -public void testOneHundredColumnSubjObjPrefix() throws Exception { + @Test + public void testContext2() throws Exception { - BatchWriter bw = null; + BatchWriter bw = null; bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); - } - - if (i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); + + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 4 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context3" + "\u0000" +"obj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); + } - - - - - bw.addMutation(m); } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); - TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("subj")); + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("obj")); tc3.setIsPrefix(true); - + TextColumn[] tc = new TextColumn[3]; tc[0] = tc1; tc[1] = tc2; tc[2] = tc3; + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - dii.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setContext(is, "context2"); Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); int results = 0; - System.out.println("************************Test 7****************************"); + System.out.println("************************Test 15****************************"); for (Map.Entry<Key, Value> e : scan) { System.out.println(e); results++; } - - - Assert.assertEquals(4, results); - - -} + Assert.assertEquals(0, results); + + + + + } -@Test -public void testOneHundredColumnSubjObjPrefixFourTerms() throws Exception { - BatchWriter bw = null; + + @Test + public void testContext3() throws Exception { + + BatchWriter bw = null; bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + + for (int i = 0; i < 100; i++) { Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf" + j), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); - } - - if (i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + (100 + i)), new Value(new byte[0])); - m.put(new Text("cf" + 100), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + (100 + i + 1)), new Value(new byte[0])); + + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 1 + "\u0000" + "context1"), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 2 + "\u0000" + "context1"), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 1 + "\u0000" + "context2"), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 2 + "\u0000" + "context2"), new Value(new byte[0])); + + + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 4 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context3" + "\u0000" +"obj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); + } - - - - - bw.addMutation(m); } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 20), new Text("obj" + "\u0000" + "cq" + 20)); - TextColumn tc2 = new TextColumn(new Text("cf" + 50), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" + 100), new Text("subj")); - TextColumn tc4 = new TextColumn(new Text("cf" + 100), new Text("obj")); + + + + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("obj")); tc3.setIsPrefix(true); - tc4.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[4]; + + TextColumn[] tc = new TextColumn[3]; tc[0] = tc1; tc[1] = tc2; tc[2] = tc3; - tc[3] = tc4; + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - dii.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setContext(is, "context2"); Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); int results = 0; - System.out.println("************************Test 8****************************"); + System.out.println("************************Test 16****************************"); for (Map.Entry<Key, Value> e : scan) { System.out.println(e); results++; } - - + + Assert.assertEquals(4, results); - - -} + } -//@Test -public void testOneHundredColumnSameCf() throws Exception { - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - - for(int j= 0; j < 100; j++) { - m.put(new Text("cf"), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + j), new Value(new byte[0])); - } - - - bw.addMutation(m); + @Test + public void testContext4() throws Exception { - } - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" ), new Text("obj" + "\u0000" + "cq" + 20)); - TextColumn tc2 = new TextColumn(new Text("cf"), new Text("obj" + "\u0000" + "cq" + 50)); - TextColumn tc3 = new TextColumn(new Text("cf" ), new Text("obj" + "\u0000" + "cq" + 80)); - TextColumn tc4 = new TextColumn(new Text("cf"), new Text("obj")); + BatchWriter bw = null; - tc4.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[4]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - tc[3] = tc4; + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - dii.setColumnFamilies(is, tc); - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); + for (int i = 0; i < 100; i++) { - int results = 0; - System.out.println("************************Test 9****************************"); - for (Map.Entry<Key, Value> e : scan) { - //System.out.println(e); - results++; - } - - - Assert.assertEquals(10000, results); + Mutation m = new Mutation(new Text("" + i)); - - + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); -} + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context2" + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + } + bw.addMutation(m); -@Test -public void testGeneralStarQuery() throws Exception { + } - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - for (int i = 0; i < 100; i++) { + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("obj")); - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - - + tc3.setIsPrefix(true); - if(i == 30 || i == 60 ) { - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - } - - bw.addMutation(m); + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; - } - - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); - TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); - TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3)); - - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 10****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(2, results); - - - -} + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + int results = 0; + System.out.println("************************Test 17****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } -@Test -public void testGeneralStarQuerySubjPrefix() throws Exception { + Assert.assertEquals(8, results); - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); - - - if(i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - } - - bw.addMutation(m); + } - } - - - DocumentIndexIntersectingIterator dii = new DocumentIndexIntersectingIterator(); - TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); - TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); - TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); - - tc3.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - dii.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 11****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(4, results); - - - -} + @Test + public void testContext5() throws Exception { + BatchWriter bw = null; -@Test -public void testGeneralStarQueryMultipleSubjPrefix() throws Exception { + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - for (int i = 0; i < 100; i++) { + for (int i = 0; i < 100; i++) { - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); - - + Mutation m = new Mutation(new Text("" + i)); - if(i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); - } - - bw.addMutation(m); + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text("context2" + "\u0000" + "obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context2" + "\u0000" + "obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text(null + "\u0000" + "obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text(null + "\u0000" + "obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - } - - - - TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); - TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); - TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); - - tc3.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 12****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(12, results); - - - -} + if(i == 30 || i == 60 || i == 90 || i == 99) { + m.put(new Text("cf" + 3), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text("context2" + "\u0000" + "obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + m.put(new Text("cf" + 3), new Text(null + "\u0000" + "obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); + } + bw.addMutation(m); -@Test -public void testFixedRangeColumnValidateExact() throws Exception { + } - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - for (int i = 0; i < 100; i++) { + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); + TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("obj")); - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); - - + tc3.setIsPrefix(true); - if(i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); - } - - bw.addMutation(m); + TextColumn[] tc = new TextColumn[3]; + tc[0] = tc1; + tc[1] = tc2; + tc[2] = tc3; - } - - - - TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); - TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); - TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3)); - TextColumn tc4 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 4)); - TextColumn tc5 = new TextColumn(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 5)); - - - - TextColumn[] tc = new TextColumn[5]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - tc[3] = tc4; - tc[4] = tc5; - - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.setRange(Range.exact(new Text("" + 30))); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 14****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(1, results); - - - -} + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); + scan.addScanIterator(is); + int results = 0; + System.out.println("************************Test 18****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } -@Test -public void testLubmLikeTest() throws Exception { - BatchWriter bw = null; + Assert.assertEquals(12, results); - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - for (int i = 0; i < 100; i++) { - Mutation m1 = new Mutation(new Text("ProfessorA" + i)); - Mutation m2= new Mutation(new Text("ProfessorB" + i)); - - m1.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom";), - new Text(null + "\u0000" +"object" + "\u0000" + "http://www.University"; + i + ".edu"), new Value(new byte[0])); - m2.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom";), - new Text(null + "\u0000" +"object" + "\u0000" + "http://www.University"; + i + ".edu"), new Value(new byte[0])); - m1.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), - new Text(null + "\u0000" +"object" + "\u0000" + "http://Course"; + i), new Value(new byte[0])); - m2.put(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), - new Text(null + "\u0000" +"object" + "\u0000" + "http://Course"; + i), new Value(new byte[0])); - - - bw.addMutation(m1); - bw.addMutation(m2); - } - - - - TextColumn tc1 = new TextColumn(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#doctoralDegreeFrom"; ), - new Text("object" + "\u0000" + "http://www.University"; + 30 + ".edu")); - TextColumn tc2 = new TextColumn(new Text("http://swat.cse.lehigh.edu/onto/univ-bench.owl#teacherOf";), - new Text("object" + "\u0000" + "http://Course"; + 30)); - + } - - TextColumn[] tc = new TextColumn[2]; - tc[0] = tc1; - tc[1] = tc2; - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.addScanIterator(is); - int results = 0; - System.out.println("************************Test 15****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(2, results); + @Test + public void testContext6() throws Exception { - - + BatchWriter bw = null; -} + bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + for (int i = 0; i < 100; i++) { + Mutation m = new Mutation(new Text("row" + i)); + m.put(new Text("cf" + 1), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + i), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context1" + "\u0000" + "subj" + "\u0000" + "cq" + i), new Value(new byte[0])); + m.put(new Text("cf" + 1), new Text("context2" + "\u0000" + "obj" + "\u0000" + "cq" + i), new Value(new byte[0])); + m.put(new Text("cf" + 2), new Text("context2" + "\u0000" + "subj" + "\u0000" + "cq" + i), new Value(new byte[0])); + bw.addMutation(m); + } + TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" )); + TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("subj" )); + tc1.setIsPrefix(true); + tc2.setIsPrefix(true); + TextColumn[] tc = new TextColumn[2]; + tc[0] = tc1; + tc[1] = tc2; -@Test -public void testFixedRangeColumnValidateSubjPrefix() throws Exception { - BatchWriter bw = null; - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); + IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - - for (int i = 0; i < 100; i++) { + DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); + DocumentIndexIntersectingIterator.setContext(is, "context2"); - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); - m.put(new Text("cf" + 1), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - - + Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - if(i == 30 || i == 60 || i == 90 || i == 99) { - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 3 ), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 4 ), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"obj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); - m.put(new Text("cf" + 3), new Text(null + "\u0000" +"subj" + "\u0000" + "cq" + 5 ), new Value(new byte[0])); - } - - bw.addMutation(m); + scan.addScanIterator(is); - } - - - - TextColumn tc1 = new TextColumn(new Text("cf" + 1 ), new Text("obj" + "\u0000" + "cq" + 1)); - TextColumn tc2 = new TextColumn(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2)); - TextColumn tc3 = new TextColumn(new Text("cf" + 3), new Text("subj")); - - tc3.setIsPrefix(true); - - TextColumn[] tc = new TextColumn[3]; - tc[0] = tc1; - tc[1] = tc2; - tc[2] = tc3; - - - IteratorSetting is = new IteratorSetting(30, "fii", DocumentIndexIntersectingIterator.class); - - DocumentIndexIntersectingIterator.setColumnFamilies(is, tc); - - Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); - scan.setRange(Range.exact(new Text("" + 30))); - scan.addScanIterator(is); - - int results = 0; - System.out.println("************************Test 13****************************"); - for (Map.Entry<Key, Value> e : scan) { - System.out.println(e); - results++; - } - - - Assert.assertEquals(3, results); - - - + int results = 0; + System.out.println("************************Test 19****************************"); + for (Map.Entry<Key, Value> e : scan) { + System.out.println(e); + results++; + } -} + Assert.assertEquals(100, results); -//@Test -//public void testRangeBound() { -// -// BatchWriter bw = null; -// -// try { -// -// -// -// -// for (int i = 0; i < 100; i++) { -// -// Mutation m = new Mutation(new Text("" + i)); -// -// m.put(new Text("cf" + 1), new Text("obj" + "\u0000" + "cq" + 1), new Value(new byte[0])); -// m.put(new Text("cf" + 2), new Text("obj" + "\u0000" + "cq" + 2), new Value(new byte[0])); -// m.put(new Text("cf" + 1), new Text("subj" + "\u0000" + "cq" + 1), new Value(new byte[0])); -// m.put(new Text("cf" + 2), new Text("subj" + "\u0000" + "cq" + 2), new Value(new byte[0])); -// -// -// -// if(i == 30 || i == 60 || i == 90 || i == 99) { -// m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 3), new Value(new byte[0])); -// m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 3), new Value(new byte[0])); -// m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 4), new Value(new byte[0])); -// m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 4), new Value(new byte[0])); -// m.put(new Text("cf" + 3), new Text("obj" + "\u0000" + "cq" + 5), new Value(new byte[0])); -// m.put(new Text("cf" + 3), new Text("subj" + "\u0000" + "cq" + 5), new Value(new byte[0])); -// } -// -// bw.addMutation(m); -// -// } -// -// -// -// Text cf = new Text("cf" + 3); -// Text cq = new Text("obj" + "\u0000" + "cq" + 3); -// -// Scanner scan = accCon.createScanner(tablename, new Authorizations("auths")); -// scan.fetchColumn(cf, cq ); -// scan.setRange(new Range()); -// -// -// int results = 0; -// System.out.println("************************Test 14****************************"); -// for (Map.Entry<Key, Value> e : scan) { -// System.out.println(e); -// results++; -// } -// -// -// -// -// -// -// } catch (MutationsRejectedException e) { -// // TODO Auto-generated catch block -// e.printStackTrace(); -// } catch (TableNotFoundException e) { -// // TODO Auto-generated catch block -// e.printStackTrace(); -// } -// -//} - - - - - -@Test -public void testContext1() throws Exception { - - BatchWriter bw = null; - - bw = accCon.createBatchWriter(tablename, 500L * 1024L * 1024L, Long.MAX_VALUE, 30); - - - - for (int i = 0; i < 100; i++) { - - Mutation m = new Mutation(new Text("" + i)); - - m.put(new Text("cf" + 1), new Text("context1" + "\u0000" + "obj" + "\u0000" + "cq" + 1 ), new Value(new byte[0])); - m.put(new Text("cf" + 2), new Text("context1" + "\u0000" +"obj" + "\u0000" + "cq" + 2 ), new Value(new byte[0])); - - -
<TRUNCATED>
