rya-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From puja...@apache.org
Subject [20/49] incubator-rya git commit: RYA-7 POM and License Clean-up for Apache Move
Date Fri, 04 Dec 2015 16:46:32 GMT
http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/QueryPartitionData.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/QueryPartitionData.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/QueryPartitionData.java
deleted file mode 100644
index 0f9e7e0..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/QueryPartitionData.java
+++ /dev/null
@@ -1,675 +0,0 @@
-package mvm.mmrts.rdf.partition;
-
-import org.openrdf.model.ValueFactory;
-import org.openrdf.model.impl.ValueFactoryImpl;
-import org.openrdf.query.*;
-import org.openrdf.query.resultio.sparqlxml.SPARQLResultsXMLWriter;
-import org.openrdf.repository.Repository;
-import org.openrdf.repository.RepositoryConnection;
-import org.openrdf.repository.sail.SailRepository;
-
-import java.util.Calendar;
-import java.util.List;
-
-public class QueryPartitionData {
-
-    public void run() throws Exception {
-        try {
-            // if (args.length == 0) {
-            // throw new IllegalArgumentException("Specify query file");
-            // }
-            // String fileLoc = args[0];
-            // File queryFile = new File(fileLoc);
-            // final ByteArrayOutputStream baos = new ByteArrayOutputStream();
-            // ByteStreams.copy(new FileInputStream(queryFile), baos);
-            // String query = new String(baos.toByteArray());
-
-            final PartitionSail store = new PartitionSail("stratus", "stratus13:2181", "root", "password",
-                    "partTest", "shardIndexTest");
-//            store.setTablePrefix("str_");
-//            store.getTimeUris().put(new URIImpl("http://here/2010/tracked-data-provenance/ns#performedAt"), DateTimeTtlValueConverter.class);
-//            store.getTimeUris().add(new URIImpl("http://mvm.com/rdf/2011/02/model#timestamp"));
-//            store.setPerformant(true);
-//            store.setUseStatistics(false);
-//            store.setInferencing(false);
-//            store.setDisplayQueryPlan(false);
-
-//            store.setStartTime("1302811169088");
-//            store.setTtl("86400000");
-//            store.setPerformant(false);
-//            store.setInstance("nimbus");
-//            store.setServer("10.40.189.123");
-            Repository myRepository = new SailRepository(store);
-            myRepository.initialize();
-
-//			BufferedOutputStream os = new BufferedOutputStream(
-//					new FileOutputStream("query.out"));
-
-            RepositoryConnection conn = myRepository.getConnection();
-
-            // String query =
-            // "SELECT ?pred ?obj WHERE { <http://mvm-model/mvm#mm_7afb494d-dddc-4f1c-8b5b-0413b3ebe783> ?pred ?obj }";
-            // String query =
-            // "SELECT ?pred ?obj WHERE { <http://mvm-model/mvm#mm_b10c2c18-80c3-41ef-8069-9df1a6e8879c> ?pred ?obj }";
-            // String query =
-            // "SELECT ?pred ?obj WHERE { <http://mvm-model/mvm#mm_001ca4e0-521f-440e-9e72-9b59bb14fd2c> ?pred ?obj }";
-
-            String cimHasInstalledSoftware = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "     ?serv mm:hasRunningOS ?obj .\n" +
-                    "      ?obj mm:name ?name ;\n" +
-//                    "           mm:caption ?caption .\n" +
-                    "}";
-
-            String cimHasRunningSoftware = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/mm.owl#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "     <http://mvm.com/owl/mm.owl#urn:mm:mvm:LTS:root/cimv2:PG_OperatingSystem:CIM_ComputerSystem:stratus06.bullpen.net:Red_Hat_Enterprise_Linux_Server> mm:hasRunningOS ?obj .\n" +
-                    "     ?obj mm:name ?name ; \n" +
-                    "          mm:handle ?handle ; \n" +
-                    "          mm:description ?description ; \n" +
-                    "          mm:caption ?caption . \n" +
-                    "}";
-
-            String artistQuery = "SELECT * WHERE { "
-                    + " ?subj ?pred \"Bonnie Tyler\" . "
-                    + "}";
-            String lubm1 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX ub: <urn:lubm:test#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "     ?x ub:takesCourse <http://www.Department0.University0.edu/GraduateCourse0> .\n" +
-                    "     ?x rdf:type ub:GraduateStudent .\n" +
-                    "     ?x ub:name ?name .\n" +
-//                    "     FILTER regex(?name, \"GraduateStudent44\", \"i\") .\n" +
-                    " }";
-
-            String gradStudent44 = "SELECT * WHERE { <http://www.Department0.University0.edu/GraduateStudent44> ?p ?o.}";
-
-            String lubm4 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      { ?pred rdfs:subPropertyOf ub:worksFor . ?y ?pred <http://www.Department0.University0.edu> }\n" +
-                    "       UNION " +
-                    "      { ?y ub:worksFor <http://www.Department0.University0.edu> }\n" +
-                    "      { ?x rdfs:subClassOf ub:Professor . ?y rdf:type ?x }\n" +
-                    "       UNION " +
-                    "      { ?y rdf:type ub:Professor }\n" +
-                    "      ?y ub:name ?y1 .\n" +
-                    "      ?y ub:emailAddress ?y2 .\n" +
-                    "      ?y ub:telephone ?y3 .\n" +
-                    " }";
-
-            String lubm4_clean = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      ?y ub:worksFor <http://www.Department0.University0.edu>.\n" +
-                    "      ?y rdf:type ub:FullProfessor.\n" +
-                    "      ?y ub:name ?y1 .\n" +
-                    " } ORDER BY ?y";
-
-            String cimLatestMeasure = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "SELECT ?proc ?val ?time WHERE {\n" +
-                    "     ?proc mm:loadPercentage ?val .\n" +
-                    "     ?subj rdf:subject ?proc .\n" +
-                    "     ?subj rdf:object ?val2 .\n" +
-                    "     ?subj  rdf:type rdf:Statement ;\n" +
-                    "     \t    mm:reportedAt ?time .\n" +
-                    " FILTER (?val2 = ?val) }\n" +
-                    "ORDER BY DESC(?time)\n" +
-                    "LIMIT 25";
-
-            String cimHasFileSystemSpecific = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/mm.owl#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "     <http://mvm.com/owl/mm.owl#urn:mm:mvm:lts:root/cimv2:PG_OperatingSystem.CreationClassName=CIM_OperatingSystem,CSCreationClassName=CIM_UnitaryComputerSystem,CSName=roshan.bullpen.net,Name=Red_Hat_Enterprise_Linux_Server> mm:hasFileSystem ?obj ." +
-//                "     ?serv mm:hasFileSystem ?obj ." +
-                    "}";
-
-            String allObjects = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "   {?s <http://www.w3.org/1999/02/22-rdf-syntax-ns#object> ?o.} }";
-
-            String deletePkgTrkr = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    " PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    "PREFIX prov: <http://this.doc/2010/tracked-data-provenance/ns#>\n" +
-                    " SELECT DISTINCT * WHERE\n" +
-                    " {\n" +
-                    "     ?subj rdf:type prov:AggregatePkgInfo.\n" +
-                    "     ?subj ?pred ?obj." +
-                    " }";
-
-            String lubm5 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      { ?pred rdfs:subPropertyOf ub:memberOf . ?thing ?pred <http://www.Department0.University0.edu> }\n" +
-                    "       UNION " +
-                    "      { ?thing ub:memberOf <http://www.Department0.University0.edu> }\n" +
-//                    "      { ?type rdfs:subClassOf ub:Person . ?thing rdf:type ?type }\n" +
-//                    "       UNION " +
-//                    "      { ?thing rdf:type ub:Person }\n" +
-                    " }";
-
-            String lubm5_clean = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      ?thing ub:memberOf <http://www.Department0.University0.edu>.\n" +
-                    "      ?thing rdf:type ub:Person. \n" +
-                    " }";
-
-            String lubm5_clean2 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      ?pred rdfs:subPropertyOf ub:memberOf . ?thing ?pred <http://www.Department0.University0.edu> . ?type rdfs:subClassOf ub:Person . ?thing rdf:type ?type \n" +
-                    " }";
-
-            String lubm3 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "                 PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "                 SELECT * WHERE\n" +
-                    "                 {\n" +
-                    "                      ?x ub:publicationAuthor <http://www.Department0.University0.edu/AssistantProfessor3> .\n" +
-                    "                      ?x rdf:type ub:Publication.\n" +
-                    "                }";
-
-            String lubm2 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "                 PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "                 SELECT * WHERE\n" +
-                    "                 {\n" +
-                    "                       ?y rdf:type ub:University .\n" +
-                    "                       ?z ub:subOrganizationOf ?y .\n" +
-                    "                       ?z rdf:type ub:Department .\n" +
-                    "                       ?x ub:memberOf ?z .\n" +
-                    "                       ?x ub:undergraduateDegreeFrom ?y .\n" +
-                    "                       ?x rdf:type ub:GraduateStudent .\n" +
-                    "                }";
-
-            String lubm2_a = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "                 PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "                 SELECT * WHERE\n" +
-                    "                 {\n" +
-//                    "                       ?y rdf:type ub:University .\n" +
-                    "                       ?z ub:subOrganizationOf <http://www.University700.edu> .\n" +
-                    "                       ?z rdf:type ub:Department .\n" +
-                    "                       ?x ub:memberOf ?z .\n" +
-                    "                       ?x ub:undergraduateDegreeFrom <http://www.University700.edu> .\n" +
-                    "                       ?x rdf:type ub:GraduateStudent .\n" +
-                    "                }";
-
-            String hasAlum = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    "PREFIX owl: <http://www.w3.org/2002/07/owl#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "        {<http://www.University1.edu> ub:hasAlumnus ?alum } \n" +
-                    "        UNION \n" +
-                    "        {ub:hasAlumnus owl:inverseOf ?invProp . \n" +
-                    "      { ?pred rdfs:subPropertyOf ?invProp . ?alum ?pred <http://www.University1.edu> }\n" +
-                    "         UNION \n" +
-                    "      { ?alum ?invProp <http://www.University0.edu> }}\n" +
-                    "      { ?type rdfs:subClassOf ub:Person . ?alum rdf:type ?type }\n" +
-                    "       UNION       { ?alum rdf:type ub:Person }\n" +
-                    "}";
-
-            String hasAlum_clean = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    "PREFIX owl: <http://www.w3.org/2002/07/owl#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "        <http://www.University1.edu> ub:hasAlumnus ?alum .\n" +
-                    "}";
-
-            String lubm7 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT DISTINCT ?course ?student WHERE\n" +
-                    " {\n" +
-                    " <http://www.Department0.University0.edu/AssociateProfessor0> ub:teacherOf ?course .\n" +
-                    " ?student ub:takesCourse ?course .\n" +
-                    "      { ?type rdfs:subClassOf ub:Student . ?student rdf:type ?type }\n" +
-                    "       UNION       { ?student rdf:type ub:Student }\n" +
-                    "      { ?type rdfs:subClassOf ub:Course . ?course rdf:type ?type }\n" +
-                    "       UNION       { ?course rdf:type ub:Course }\n" +
-                    " }";
-
-            String lubm7_clean = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    " <http://www.Department0.University0.edu/AssociateProfessor0> ub:teacherOf ?course .\n" +
-                    " ?student ub:takesCourse ?course .\n" +
-                    " ?student rdf:type ub:Student .\n" +
-                    " ?course rdf:type ub:Course .\n" +
-                    " }";
-
-            String lubm8_clean = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      ?suborg ub:subOrganizationOf <http://www.University0.edu> .\n" +
-                    "      ?mem ub:memberOf ?suborg .\n" +
-                    "      ?suborg rdf:type ub:Department .\n" +
-                    "        ?mem ub:emailAddress ?email. \n" +
-                    " }";
-
-            String lubm9 = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "       ?teach ub:teacherOf ?course .\n" +
-                    "       ?teach ub:advisor ?student .\n" +
-                    "        ?student ub:takesCourse ?course .\n" +
-                    " }";
-
-            String kolm = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "PREFIX kolm: <http://mvm.com/lrn/2010/11/kolm#>\n" +
-                    "SELECT DISTINCT ?srv ?ncd WHERE {\n" +
-                    "     ?pt kolm:serverRef <http://mvm.com/owl/2010/10/mm.owl#urn:mm:mvm:root/cimv2:PG_OperatingSystem:CIM_ComputerSystem:cirrus05.bullpen.net:Red_Hat_Enterprise_Linux_Server> .\n" +
-                    "     ?cluster kolm:relatesTo ?pt .\n" +
-                    "     ?cluster kolm:relatesTo ?pt2 .\n" +
-                    "     ?pt2 kolm:serverRef ?srv .\n" +
-                    "       ?pt2  kolm:ncd ?ncd .\n" +
-                    "       ?cluster kolm:timestamp ?ts .\n" +
-                    " } \n" +
-                    " ORDER BY ?ncd";
-
-            String kolm_tst = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "PREFIX kolm: <http://mvm.com/lrn/2010/11/kolm#>\n" +
-                    "SELECT * WHERE {\n" +
-                    "     ?s <http://mvm.com/lrn/2010/11/kolm#relatesTo> <http://mvm.com/lrn/2010/11/kolm#fef60314-78f1-4918-ad03-e1aff835e858>\n" +
-                    " } ";
-
-            String lubm9_tst = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "       ?teach ub:teacherOf ?course .\n" +
-//                    "       ?teach ub:teacherOf <http://www.Department0.University0.edu/Course3> .\n" +
-                    "       ?student ub:advisor ?teach .\n" +
-                    "        ?student ub:takesCourse ?course .\n" +
-                    " }";
-
-            String bsbm1 = "PREFIX bsbm-inst: <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/>\n" +
-                    "PREFIX bsbm: <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/vocabulary/>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    "\n" +
-                    "SELECT *\n" +
-                    "WHERE {\n" +
-                    "    ?product a <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductType1315> .\n" +
-                    "    ?product bsbm:productFeature <http://www4.wiwiss.fu-berlin.de/bizer/bsbm/v01/instances/ProductFeature750> .\n" +
-                    "    ?product bsbm:productPropertyNumeric1 ?value1 .\n" +
-                    "    ?product rdfs:label ?label .\n" +
-                    "        FILTER (?value1 > 933) .\n" +
-                    "        }" +
-                    "LIMIT 10" +
-                    "";
-
-            String hbs = "PREFIX hb: <http://here/2010/tracked-data-provenance/heartbeat/ns#>\n" +
-                    "\n" +
-                    "select * where {\n" +
-                    " hb:f452f776-4994-43fc-ada0-4b60cc979dac ?p ?o .\n" +
-                    "}";
-
-            String hbmodel = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mod: <http://mvm.com/rdf/2011/02/model#>\n" +
-                    "PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    "SELECT ?s (SUM(?ts) AS ?sum) WHERE\n" +
-                    "{\n" +
-                    "    ?s mod:key \"messageCount/urn:system:LTS-01/A/A_Sports1/ProvenanceAPI/2/12/\";\n" +
-                    "        mod:model ?model;\n" +
-                    "        mod:timestamp ?ts.\n" +
-                    "}\n" +
-                    "GROUP BY ?s\n" +
-                    "ORDER BY DESC(?ts)\n";
-
-            String hbagg = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX hb: <http://here/2010/tracked-data-provenance/heartbeat/ns#>\n" +
-                    " PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "     ?systemName hb:reportedBy ?reportedBy;\n" +
-                    "                         hb:systemType ?systemType;\n" +
-                    "                         hb:heartbeat ?hbuuid.\n" +
-                    "     ?hbuuid hb:timestamp ?timestamp;\n" +
-                    "                         hb:messageCount ?messageCount.\n" +
-                    " }";
-
-            String runningProc = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    " PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    " SELECT DISTINCT * WHERE\n" +
-                    " {\n" +
-                    "     <http://mvm.com/owl/2010/10/mm.owl#urn:mm:mvm:root/cimv2:PG_OperatingSystem:CIM_ComputerSystem:cirrus05.bullpen.net:Red_Hat_Enterprise_Linux_Server> mm:hasRunningProcess ?obj .\n" +
-                    "     ?obj mm:parameters ?params .\n" +
-                    "     ?obj mm:name ?name .\n" +
-                    " }";
-
-            String single = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "      <http://www.Department11.University370.edu/AssociateProfessor9> ?p ?o.\n" +
-                    " }";
-
-            String modelInnerSelect = "PREFIX nh: <http://mvm.com/rdf/2011/02/model#>\n" +
-                    "\n" +
-                    "SELECT * WHERE {\n" +
-                    "\n" +
-                    "{\n" +
-                    "SELECT ?key ?modelType (MAX(?timestamp) as ?ts) WHERE {\n" +
-                    "     ?modelUuid nh:key ?key;\n" +
-                    "     FILTER regex(?key, \"messageCount(.*)/2/13\").\n" +
-                    "     ?modelUuid nh:modelType ?modelType;\n" +
-                    "                        nh:timestamp ?timestamp\n" +
-                    "}\n" +
-                    "GROUP BY ?key ?modelType\n" +
-                    "}\n" +
-                    "\n" +
-                    "?muuid nh:key ?key;\n" +
-                    "           nh:timestamp ?ts;\n" +
-                    "           nh:modelType ?modelType;\n" +
-                    "           nh:model ?model.\n" +
-                    "\n" +
-                    "}";
-
-            String modelInnerSelect2 = "PREFIX nh: <http://mvm.com/rdf/2011/02/model#>\n" +
-                    "\n" +
-                    "SELECT ?key ?modelType (MAX(?timestamp) as ?ts) WHERE {\n" +
-                    "     ?modelUuid nh:key ?key;\n" +
-                    "     FILTER regex(?key, \"messageCount(.*)/2/13\").\n" +
-                    "     ?modelUuid nh:modelType ?modelType;\n" +
-                    "                        nh:timestamp ?timestamp\n" +
-                    "}\n" +
-                    "GROUP BY ?key ?modelType\n" +
-                    "";
-
-            String jim_query = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "\n" +
-                    "select * where {\n" +
-                    " ?eventUUID ?eventType <urn:tdo:88d4f31f-99dc-4527-8cfb-2c93583ad498> .\n" +
-//                    " ?eventUUID tdp:performedBy ?systemName .\n" +
-                    " ?eventUUID tdp:performedAt ?timeStamp .\n" +
-                    "}\n" +
-                    "ORDERBY ?timeStamp";
-
-            String theWoman = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" +
-                    " PREFIX ub: <urn:test:onto:univ#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    " ub:TheWoman ?p ?o.\n" +
-                    " }";
-
-            String hbtimestamp = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX hb: <http://here/2010/tracked-data-provenance/heartbeat/ns#>\n" +
-                    " PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "     ?hbuuid hb:timestamp ?timestamp.\n" +
-                    " }";
-
-            String tde = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mvm: <urn:mvm.mmrts.rdfcloudstore/06/2011#>\n" +
-                    "SELECT * WHERE\n" +
-                    "{\n" +
-                    "\t?id tdp:performedAt ?ts.\n" +
-                    "\tFILTER(mvm:timeRange(?ts, tdp:performedAt, 'mvm.mmrts.api.date.DateTimeTtlValueConverter', 7200000, '1303911164088')).\n" +
-                    "\t?id tdp:performedBy ?system;\n" +
-                    "\t    rdf:type ?eventType.\n" +
-                    "}\n";
-
-            String tde_spec = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "SELECT * WHERE\n" +
-                    "{\n" +
-                    "\t<urn:tde:0b19e224-7524-4ba0-880b-16d9ec735303> ?p ?o.\n" +
-                    "}";
-
-            String cimLatestMeasure_timeindex = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mm: <http://mvm.com/owl/2010/10/mm.owl#>\n" +
-                    "PREFIX mvm: <urn:mvm.mmrts.rdfcloudstore/06/2011#>\n" +
-                    "SELECT ?proc ?val ?time WHERE {\n" +
-                    "     ?proc mm:loadPercentage ?val .\n" +
-                    "     ?subj rdf:subject ?proc .\n" +
-                    "     ?subj rdf:object ?val2 .\n" +
-                    "     ?subj  rdf:type rdf:Statement ;\n" +
-                    "     \t    mm:reportedAt ?time .\n" +
-                    "\tFILTER (mvm:timeRange(?time, mm:reportedAt, 'mvm.mmrts.api.date.DateTimeTtlValueConverter', '86400000', '1295725236000')). " +
-                    "}\n" +
-//                    "ORDER BY DESC(?time)\n" +
-//                    "LIMIT 25" +
-                    "";
-
-            String hbs_ti = "PREFIX hb: <http://here/2010/tracked-data-provenance/heartbeat/ns#>\n" +
-                    "\n" +
-                    "select * where {\n" +
-                    " ?s ?p hb:f452f776-4994-43fc-ada0-4b60cc979dac .\n" +
-                    "}";
-
-            String hbtimestamp_ti = "PREFIX hb: <http://here/2010/tracked-data-provenance/heartbeat/ns#>\n" +
-                    "PREFIX xsd: <http://www.w3.org/2001/XMLSchema#>\n" +
-                    "PREFIX mvm: <urn:mvm.mmrts.rdfcloudstore/06/2011#>\n" +
-                    "SELECT * WHERE\n" +
-                    "{\n" +
-                    "\t?id hb:timestamp ?timestamp.\n" +
-                    "\tFILTER(mvm:timeRange(?timestamp, hb:timestamp, 'mvm.mmrts.api.date.TimestampTtlStrValueConverter', '72000000')).\n" +
-                    "\t?id hb:systemName ?system;\n" +
-                    "\t     hb:count ?count;\n" +
-                    "}";
-
-            String tst_qu = "select * where {\n" +
-                    "\n" +
-                    " ?s <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <urn:test2:lubm#GraduateStudent>.\n" +
-                    " ?s <urn:test2:lubm#advisor> <http://www.Department4.University5155.edu/AssociateProfessor3>.\n" +
-//                    " ?s ?p ?o.\n" +
-                    "\n" +
-                    "}";
-
-            String tst_qu2 = "select * where {\n" +
-                    "\n" +
-                    "?s <urn:test2:lubm#takesCourse> <http://www.Department6.University4518.edu/GraduateCourse3>.\n" +
-                    "?s <urn:test2:lubm#takesCourse> <http://www.Department6.University4518.edu/GraduateCourse28>.\n" +
-                    "\n" +
-                    "}";
-
-            String timeQueryMike = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mvm: <urn:mvm.mmrts.rdfcloudstore/06/2011#>\n" +
-                    "SELECT * WHERE\n" +
-                    "{\n" +
-                    "?id tdp:reportedAt ?timestamp. \n" +
-                    "FILTER(mvm:timeRange(?timestamp, tdp:reportedAt, 'mvm.mmrts.api.date.DateTimeTtlValueConverter', '14400000')).\n" +
-                    "?id tdp:performedBy ?system;\n" +
-                    "    rdf:type ?eventType.\n" +
-                    "} ";
-
-            String eventQ = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "select * where {\n" +
-                    "?eventUUID tdp:performedBy ?systemName .\n" +
-                    "} LIMIT 100";
-
-            String allFullProf0 = "select * where {\n" +
-                    "<http://www.Department0.University0.edu/FullProfessor0> ?p ?o.\n" +
-                    "\n}";
-
-            // Provenance Queries
-            String prov_eventInfo = "select * where {\n" +
-                    "<urn:tdo:7202e20d-d66c-469c-8a10-62e36e21d820> ?p ?o.\n" +
-                    "}";
-
-            String prov_objectInfo = "PREFIX ns:<http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "select * where {\n" +
-                    "{" +
-                    "   ?s ns:createdItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:clickedItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:deletedItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:droppedItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:receivedItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:storedItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "UNION {" +
-                    "   ?s ns:sentItem <urn:tdc:01a49336-d0e0-3cd6-9ddb-0e6b14369876>.\n" +
-                    "   ?s ns:performedBy ?pb.\n" +
-                    "   ?s ns:performedAt ?pa.\n" +
-                    "}\n" +
-                    "}\n";
-
-            String prov_createdItems = "PREFIX ns: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "\n" +
-                    "select * where {\n" +
-                    "\n" +
-                    "  ?s ns:createdItem ?i\n" +
-                    " \n" +
-                    "} limit 10";
-            ////////////////////
-
-            String rangeQuery = "PREFIX tdp: <http://here/2010/tracked-data-provenance/ns#>\n" +
-                    "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    "PREFIX mvmpart: <urn:mvm.mmrts.partition.rdf/08/2011#>\n" +
-                    "SELECT * WHERE\n" +
-                    "{\n" +
-                    "?id tdp:reportedAt ?timestamp.\n" +
-                    "FILTER(mvmpart:timeRange(?id, tdp:reportedAt, 1314849589999 , 1314849599999 , 'XMLDATETIME')).\n" +
-                    "?id tdp:performedBy ?system.\n" +
-                    "?id rdf:type ?type.\n" +
-                    "}";
-
-            String issueMMRTS127 = "select * where \n" +
-                    "{ \n" +
-                    "<urn:system:null> ?p ?o. \n" +
-                    "?o ?p2 ?o2. \n" +
-                    "} ";
-
-            String uuid1 = "select * where { " +
-                    "?u <http://here/2010/tracked-data-provenance/ns#performedAt> ?pa; " +
-                    "   <http://here/2010/tracked-data-provenance/ns#reportedAt> ?ra; " +
-                    "   <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> ?t. " +
-                    "}";
-
-            String uuidAuth1 = "select * where { " +
-                    "<http://here/2010/tracked-data-provenance/ns#uuidAuth1> ?p ?o. " +
-                    "}";
-
-            String selectAll = "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n" +
-                    " PREFIX ub: <urn:lubm:test#>\n" +
-                    " SELECT * WHERE\n" +
-                    " {\n" +
-                    "     ?x ub:takesCourse ?c .\n" +
-                    "     ?x rdf:type ?gs .\n" +
-                    "     ?x ub:name 'UndergraduateStudent139'.\n" +
-                    " }";
-
-            String query = uuidAuth1;
-
-            Calendar start_cal = Calendar.getInstance();
-            start_cal.set(Calendar.MONTH, 7);
-            start_cal.set(Calendar.DAY_OF_MONTH, 13);
-
-            Calendar end_cal = Calendar.getInstance();
-            end_cal.set(Calendar.MONTH, 7);
-            end_cal.set(Calendar.DAY_OF_MONTH, 14);
-
-            System.out.println(query);
-            long start = System.currentTimeMillis();
-            TupleQuery tupleQuery = conn.prepareTupleQuery(
-                    QueryLanguage.SPARQL, query);
-            ValueFactory vf = ValueFactoryImpl.getInstance();
-//            tupleQuery.setBinding(NUMTHREADS_PROP, vf.createLiteral(10));
-//            tupleQuery.setBinding(AUTHORIZATION_PROP, vf.createLiteral("C"));
-//            tupleQuery.setBinding(START_BINDING, vf.createLiteral(start_cal.getTimeInMillis()));
-//            tupleQuery.setBinding(END_BINDING, vf.createLiteral(end_cal.getTimeInMillis()));
-//            tupleQuery.setBinding(START_BINDING, vf.createLiteral(1313779878435l));
-//            tupleQuery.setBinding(END_BINDING, vf.createLiteral(1313779978435l));
-
-//            TupleQueryResultHandler writer = new SPARQLResultsXMLWriter(new NullOutputStream());
-            TupleQueryResultHandler writer = new SPARQLResultsXMLWriter(System.out);
-//            tupleQuery.evaluate(writer);
-            tupleQuery.evaluate(new TupleQueryResultHandler() {
-
-                int count = 0;
-
-                @Override
-                public void startQueryResult(List<String> strings) throws TupleQueryResultHandlerException {
-                }
-
-                @Override
-                public void endQueryResult() throws TupleQueryResultHandlerException {
-                    System.out.println(count);
-                }
-
-                @Override
-                public void handleSolution(BindingSet bindingSet) throws TupleQueryResultHandlerException {
-                    count++;
-                    System.out.println(bindingSet);
-                }
-            });
-            System.out.println("Total query time: "
-                    + (System.currentTimeMillis() - start));
-
-            conn.close();
-//			os.close();
-
-            // for (String string : urls) {
-            // ByteStreams
-            // }
-            myRepository.shutDown();
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
-    }
-
-    public static void main(String[] args) {
-        try {
-            new QueryPartitionData().run();
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-        System.exit(0);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBed.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBed.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBed.java
deleted file mode 100644
index 084cd2e..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBed.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package mvm.mmrts.rdf.partition;
-
-import cloudbase.core.client.BatchScanner;
-import cloudbase.core.client.Connector;
-import cloudbase.core.client.ZooKeeperInstance;
-import cloudbase.core.data.Key;
-import cloudbase.core.data.Range;
-import cloudbase.core.data.Value;
-import com.google.common.io.ByteStreams;
-import mvm.mmrts.rdf.partition.utils.RdfIO;
-import ss.cloudbase.core.iterators.CellLevelRecordIterator;
-import ss.cloudbase.core.iterators.SortedRangeIterator;
-import ss.cloudbase.core.iterators.filter.CBConverter;
-
-import java.util.Collections;
-import java.util.Iterator;
-import java.util.Map;
-
-import static mvm.mmrts.rdf.partition.PartitionConstants.*;
-
-/**
- * Class TstBed
- * Date: Aug 2, 2011
- * Time: 9:22:11 AM
- */
-public class TstBed {
-    public static void main(String[] args) {
-        try {
-
-            String predicate = "http://here/2010/tracked-data-provenance/ns#createdItem";
-
-            Connector connector = new ZooKeeperInstance("stratus", "stratus13:2181").getConnector("root", "password");
-            BatchScanner bs = connector.createBatchScanner("partitionRdf", ALL_AUTHORIZATIONS, 3);
-
-            bs.setScanIterators(21, CellLevelRecordIterator.class.getName(), "ci");
-
-            bs.setScanIterators(20, SortedRangeIterator.class.getName(), "ri");
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_DOC_COLF, DOC.toString());
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_COLF, INDEX.toString());
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_START_INCLUSIVE, "" + true);
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_END_INCLUSIVE, "" + true);
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_MULTI_DOC, "" + true);
-
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_LOWER_BOUND,
-                    "\07http://here/2010/tracked-data-provenance/ns#reportedAt\u0001\u000B2011-08-26T18:01:51.000Z"
-            );
-            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_UPPER_BOUND,
-                    "\07http://here/2010/tracked-data-provenance/ns#reportedAt\u0001\u000B2011-08-26T18:01:51.400Z"
-            );
-
-            Range range = new Range(
-                    new Key("2011-08\0"),
-                    new Key("2011-08\uFFFD")
-            );
-
-//            scanner.setRange(range);
-            bs.setRanges(Collections.singleton(range));
-//            bs.fetchColumnFamily(INDEX);
-//            bs.setColumnFamilyRegex(INDEX.toString());
-//            bs.setColumnQualifierRegex(URI_MARKER_STR + predicate + INDEX_DELIM_STR + "(.*)");
-
-            int count = 0;
-            Iterator<Map.Entry<Key, Value>> iter = bs.iterator();
-            CBConverter converter = new CBConverter();
-            while (iter.hasNext()) {
-                count++;
-//                iter.next();
-                Map.Entry<Key, Value> entry = iter.next();
-                Value value = entry.getValue();
-//                System.out.println(entry.getKey().getColumnQualifier() + "----" + value);
-                org.openrdf.model.Value subj = RdfIO.readValue(ByteStreams.newDataInput(entry.getKey().getColumnQualifier().getBytes()), VALUE_FACTORY, FAMILY_DELIM);
-                Map<String, String> map = converter.toMap(entry.getKey(), value);
-                for (Map.Entry<String, String> e : map.entrySet()) {
-                    String predObj = e.getKey();
-                    String[] split = predObj.split("\0");
-                    byte[] look = split[0].getBytes();
-                    System.out.println(subj
-                            + " : " + VALUE_FACTORY.createURI(split[0]) + " : " +
-                            RdfIO.readValue(ByteStreams.newDataInput(split[1].getBytes()), VALUE_FACTORY, FAMILY_DELIM));
-                }
-            }
-            System.out.println(count);
-
-            bs.close();
-
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBedGMDen.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBedGMDen.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBedGMDen.java
deleted file mode 100644
index 44309e2..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstBedGMDen.java
+++ /dev/null
@@ -1,94 +0,0 @@
-package mvm.mmrts.rdf.partition;
-
-import cloudbase.core.client.BatchScanner;
-import cloudbase.core.client.Connector;
-import cloudbase.core.client.ZooKeeperInstance;
-import cloudbase.core.data.Key;
-import cloudbase.core.data.Range;
-import cloudbase.core.data.Value;
-import com.google.common.io.ByteStreams;
-import mvm.mmrts.rdf.partition.utils.RdfIO;
-import org.apache.hadoop.io.Text;
-import org.openrdf.query.algebra.Var;
-import ss.cloudbase.core.iterators.CellLevelRecordIterator;
-import ss.cloudbase.core.iterators.GMDenIntersectingIterator;
-import ss.cloudbase.core.iterators.SortedRangeIterator;
-import ss.cloudbase.core.iterators.filter.CBConverter;
-
-import java.util.Collections;
-import java.util.Iterator;
-import java.util.Map;
-
-import static mvm.mmrts.rdf.partition.PartitionConstants.*;
-
-/**
- * Class TstBed
- * Date: Aug 2, 2011
- * Time: 9:22:11 AM
- */
-public class TstBedGMDen {
-    public static void main(String[] args) {
-        try {
-
-            Connector connector = new ZooKeeperInstance("stratus", "stratus13:2181").getConnector("root", "password");
-            BatchScanner bs = connector.createBatchScanner("rdfPartition", ALL_AUTHORIZATIONS, 3);
-
-            String[] predicates = {"urn:lubm:test#takesCourse",
-                                   "urn:lubm:test#name",
-                                   "urn:lubm:test#specific",
-                                   "http://www.w3.org/1999/02/22-rdf-syntax-ns#type"};
-
-            Text[] queries = new Text[predicates.length];
-            for (int i = 0; i < predicates.length; i++) {
-                String predicate = predicates[i];
-                queries[i] = new Text(GMDenIntersectingIterator.getRangeTerm(INDEX.toString(),
-                        URI_MARKER_STR + predicate + INDEX_DELIM_STR + "\0"
-                        , true,
-                        URI_MARKER_STR + predicate + INDEX_DELIM_STR + "\uFFFD",
-                        true
-                ));
-                System.out.println(queries[i]);
-            }
-
-            bs.setScanIterators(21, CellLevelRecordIterator.class.getName(), "ci");
-
-            bs.setScanIterators(20, GMDenIntersectingIterator.class.getName(), "ii");
-            bs.setScanIteratorOption("ii", GMDenIntersectingIterator.docFamilyOptionName, DOC.toString());
-            bs.setScanIteratorOption("ii", GMDenIntersectingIterator.indexFamilyOptionName, INDEX.toString());
-            bs.setScanIteratorOption("ii", GMDenIntersectingIterator.columnFamiliesOptionName, GMDenIntersectingIterator.encodeColumns(queries));
-            bs.setScanIteratorOption("ii", GMDenIntersectingIterator.OPTION_MULTI_DOC, "" + true);
-
-            Range range = new Range(
-                    new Key("2011-11\0"),
-                    new Key("2011-11\uFFFD")
-            );
-
-            bs.setRanges(Collections.singleton(range));
-
-            int count = 0;
-            Iterator<Map.Entry<Key, Value>> iter = bs.iterator();
-            CBConverter converter = new CBConverter();
-            while (iter.hasNext()) {
-                count++;
-                Map.Entry<Key, Value> entry = iter.next();
-                Value value = entry.getValue();
-                org.openrdf.model.Value subj = RdfIO.readValue(ByteStreams.newDataInput(entry.getKey().getColumnQualifier().getBytes()), VALUE_FACTORY, FAMILY_DELIM);
-                Map<String, String> map = converter.toMap(entry.getKey(), value);
-                for (Map.Entry<String, String> e : map.entrySet()) {
-                    String predObj = e.getKey();
-                    String[] split = predObj.split("\0");
-                    byte[] look = split[0].getBytes();
-                    System.out.println(subj
-                            + " : " + VALUE_FACTORY.createURI(split[0]) + " : " +
-                            RdfIO.readValue(ByteStreams.newDataInput(split[1].getBytes()), VALUE_FACTORY, FAMILY_DELIM));
-                }
-            }
-            System.out.println(count);
-
-            bs.close();
-
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstDocumentReader.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstDocumentReader.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstDocumentReader.java
deleted file mode 100644
index 7723431..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstDocumentReader.java
+++ /dev/null
@@ -1,217 +0,0 @@
-//package mvm.mmrts.rdf.partition;
-//
-//import cloudbase.core.CBConstants;
-//import cloudbase.core.client.Connector;
-//import cloudbase.core.client.ZooKeeperInstance;
-//import cloudbase.core.client.mock.MockInstance;
-//import cloudbase.core.data.Key;
-//import cloudbase.core.data.Range;
-//import cloudbase.core.data.Value;
-//import cloudbase.core.util.TextUtil;
-//import mvm.mmrts.cloudbase.utils.client.DocumentBatchScanner;
-//import mvm.mmrts.cloudbase.utils.client.DocumentConnectorImpl;
-//import mvm.mmrts.rdf.partition.shard.DateHashModShardValueGenerator;
-//import org.apache.hadoop.io.Text;
-//import org.apache.log4j.Level;
-//import org.apache.log4j.Logger;
-//import org.openrdf.model.ValueFactory;
-//import org.openrdf.model.impl.StatementImpl;
-//import org.openrdf.model.impl.ValueFactoryImpl;
-//import org.openrdf.repository.RepositoryException;
-//import org.openrdf.repository.sail.SailRepository;
-//import org.openrdf.repository.sail.SailRepositoryConnection;
-//import ss.cloudbase.core.iterators.SortedRangeIterator;
-//
-//import javax.xml.datatype.DatatypeConfigurationException;
-//import javax.xml.datatype.DatatypeFactory;
-//import java.util.Collections;
-//import java.util.Iterator;
-//import java.util.List;
-//import java.util.Map;
-//
-//import static mvm.mmrts.rdf.partition.PartitionConstants.*;
-//
-///**
-// * Class TstDocumentReader
-// * Date: Sep 8, 2011
-// * Time: 9:11:27 AM
-// */
-//public class TstDocumentReader {
-//    public static final String NAMESPACE = "http://here/2010/tracked-data-provenance/ns#";//44 len
-//    public static final String RDF_NS = "http://www.w3.org/1999/02/22-rdf-syntax-ns#";
-//    public static final String HBNAMESPACE = "http://here/2010/tracked-data-provenance/heartbeat/ns#";
-//    public static final String HB_TIMESTAMP = HBNAMESPACE + "timestamp";
-//
-//    private static SailRepository repository;
-//    private static SailRepositoryConnection connection;
-//
-//    private static ValueFactory vf = ValueFactoryImpl.getInstance();
-//
-//    private static final String TABLE = "partitionRdf";
-//    private static final long START = 1309532965000l;
-//    private static final long END = 1310566686000l;
-//    private static String objectUuid = "objectuuid1";
-//
-//    public static void main(String[] args) {
-//        try {
-////            Logger.getRootLogger().setLevel(Level.TRACE);
-//            DocumentConnectorImpl connector = new DocumentConnectorImpl(new ZooKeeperInstance("stratus", "stratus13:2181"), "root", "password".getBytes());
-////            DocumentConnectorImpl connector = new DocumentConnectorImpl(new MockInstance(), "", "".getBytes());
-//
-////            PartitionSail sail = new PartitionSail(connector, TABLE, new DateHashModShardValueGenerator() {
-////                @Override
-////                public String generateShardValue(Object obj) {
-////                    return this.generateShardValue(START + 1000, obj);
-////                }
-////            });
-////
-////            repository = new SailRepository(sail);
-////            repository.initialize();
-////            connection = repository.getConnection();
-////
-////            loadData();
-//
-//            DocumentBatchScanner bs = connector.createDocumentBatchScanner(TABLE, CBConstants.NO_AUTHS, 2);
-//
-//            bs.setScanIterators(20, SortedRangeIterator.class.getName(), "ri");
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_DOC_COLF, DOC.toString());
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_COLF, INDEX.toString());
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_START_INCLUSIVE, "" + true);
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_END_INCLUSIVE, "" + true);
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_MULTI_DOC, "" + true);
-//
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_LOWER_BOUND,
-//                    "\07http://here/2010/tracked-data-provenance/ns#reportedAt\u0001\u000B2011-08-26T18:01:51Z"
-//            );
-//            bs.setScanIteratorOption("ri", SortedRangeIterator.OPTION_UPPER_BOUND,
-//                    "\07http://here/2010/tracked-data-provenance/ns#reportedAt\u0001\u000B2011-08-26T18:02:00Z"
-//            );
-//
-//            Range range = new Range(
-//                    new Key("2011-08\0"),
-//                    new Key("2011-08\uFFFD")
-//            );
-//
-//            bs.setRanges(Collections.singleton(range));
-//
-//            int count = 0;
-//            int innerCount = 0;
-//            Iterator<List<? extends Map.Entry<Key, Value>>> iter = bs.documentIterator();
-//            while (iter.hasNext()) {
-//                count++;
-//                List<? extends Map.Entry<Key, Value>> entries = iter.next();
-//                for (Map.Entry<Key, Value> entry : entries) {
-//                    System.out.print(entry.getKey().getColumnQualifier());
-//                    System.out.println(" ");
-//                    innerCount++;
-//                }
-//                System.out.println();
-//            }
-//            System.out.println(count);
-//            System.out.println(innerCount);
-//
-//            bs.close();
-////            connection.close();
-////            repository.shutDown();
-//
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//    }
-//
-//    private static void loadData() throws RepositoryException, DatatypeConfigurationException {
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, objectUuid), vf.createURI(NAMESPACE, "name"), vf.createLiteral("objUuid")));
-//        //created
-//        String uuid = "uuid1";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Created")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "createdItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:A")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "stringLit"), vf.createLiteral("stringLit1")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "stringLit"), vf.createLiteral("stringLit2")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "stringLit"), vf.createLiteral("stringLit3")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "stringLit"), vf.createLiteral("stringLit4")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "strLit1"), vf.createLiteral("strLit1")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "strLit1"), vf.createLiteral("strLit2")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "strLit1"), vf.createLiteral("strLit3")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 0, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 1, 0, 0, 0))));
-//        //clicked
-//        uuid = "uuid2";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Clicked")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "clickedItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:B")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 2, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 3, 0, 0, 0))));
-//        //deleted
-//        uuid = "uuid3";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Deleted")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "deletedItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:C")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 4, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 5, 0, 0, 0))));
-//        //dropped
-//        uuid = "uuid4";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Dropped")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "droppedItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:D")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 6, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 7, 0, 0, 0))));
-//        //received
-//        uuid = "uuid5";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Received")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "receivedItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:E")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 8, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 9, 0, 0, 0))));
-//        //sent
-//        uuid = "uuid6";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Sent")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "sentItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:F")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 10, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 11, 0, 0, 0))));
-//        //stored
-//        uuid = "uuid7";
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(RDF_NS, "type"), vf.createURI(NAMESPACE, "Stored")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "storedItem"), vf.createURI(NAMESPACE, objectUuid)));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedBy"), vf.createURI("urn:system:G")));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "performedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 12, 0, 0, 0))));
-//        connection.add(new StatementImpl(vf.createURI(NAMESPACE, uuid), vf.createURI(NAMESPACE, "reportedAt"), vf.createLiteral(DatatypeFactory.newInstance().newXMLGregorianCalendar(2011, 7, 12, 6, 13, 0, 0, 0))));
-//
-//        //heartbeats
-//        String hbuuid = "hbuuid1";
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(RDF_NS, "type"), vf.createURI(HBNAMESPACE, "HeartbeatMeasurement")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HB_TIMESTAMP), vf.createLiteral((START + 1) + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "count"), vf.createLiteral(1 + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "systemName"), vf.createURI("urn:system:A")));
-//        connection.add(new StatementImpl(vf.createURI("urn:system:A"), vf.createURI(HBNAMESPACE, "heartbeat"), vf.createURI(HBNAMESPACE, hbuuid)));
-//
-//        hbuuid = "hbuuid2";
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(RDF_NS, "type"), vf.createURI(HBNAMESPACE, "HeartbeatMeasurement")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HB_TIMESTAMP), vf.createLiteral((START + 2) + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "count"), vf.createLiteral(2 + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "systemName"), vf.createURI("urn:system:B")));
-//        connection.add(new StatementImpl(vf.createURI("urn:system:B"), vf.createURI(HBNAMESPACE, "heartbeat"), vf.createURI(HBNAMESPACE, hbuuid)));
-//
-//        hbuuid = "hbuuid3";
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(RDF_NS, "type"), vf.createURI(HBNAMESPACE, "HeartbeatMeasurement")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HB_TIMESTAMP), vf.createLiteral((START + 3) + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "count"), vf.createLiteral(3 + "")));
-//        connection.add(new StatementImpl(vf.createURI(HBNAMESPACE, hbuuid), vf.createURI(HBNAMESPACE, "systemName"), vf.createURI("urn:system:C")));
-//        connection.add(new StatementImpl(vf.createURI("urn:system:C"), vf.createURI(HBNAMESPACE, "heartbeat"), vf.createURI(HBNAMESPACE, hbuuid)));
-//
-//        connection.add(new StatementImpl(vf.createURI("urn:subj1"), vf.createURI("urn:pred"), vf.createLiteral("obj1")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj1"), vf.createURI("urn:pred"), vf.createLiteral("obj2")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj1"), vf.createURI("urn:pred"), vf.createLiteral("obj3")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj1"), vf.createURI("urn:pred"), vf.createLiteral("obj4")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj2"), vf.createURI("urn:pred"), vf.createLiteral("obj1")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj2"), vf.createURI("urn:pred"), vf.createLiteral("obj2")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj2"), vf.createURI("urn:pred"), vf.createLiteral("obj3")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj2"), vf.createURI("urn:pred"), vf.createLiteral("obj4")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj3"), vf.createURI("urn:pred"), vf.createLiteral("obj1")));
-//        connection.add(new StatementImpl(vf.createURI("urn:subj3"), vf.createURI("urn:pred"), vf.createLiteral("obj4")));
-//        connection.commit();
-//    }
-//
-//
-//}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstScanner.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstScanner.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstScanner.java
deleted file mode 100644
index 6650cf1..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/TstScanner.java
+++ /dev/null
@@ -1,59 +0,0 @@
-package mvm.mmrts.rdf.partition;
-
-import cloudbase.core.client.BatchScanner;
-import cloudbase.core.client.Connector;
-import cloudbase.core.client.ZooKeeperInstance;
-import cloudbase.core.data.Key;
-import cloudbase.core.data.Range;
-import cloudbase.core.data.Value;
-import org.apache.hadoop.io.Text;
-import ss.cloudbase.core.iterators.SortedRangeIterator;
-
-import java.util.Collections;
-import java.util.Iterator;
-import java.util.Map;
-
-import static mvm.mmrts.rdf.partition.PartitionConstants.*;
-
-/**
- * Class TstBed
- * Date: Aug 2, 2011
- * Time: 9:22:11 AM
- */
-public class TstScanner {
-    public static void main(String[] args) {
-        try {
-            Connector connector = new ZooKeeperInstance("stratus", "stratus13:2181").getConnector("root", "password");
-            BatchScanner bs = connector.createBatchScanner("partitionRdf", ALL_AUTHORIZATIONS, 3);
-
-            Text shard = new Text("2011-08-40");
-            String uri = "urn:tde:c5e2f4d8-a5a6-48d8-ba55-1acea969c38d";
-            bs.setRanges(Collections.singleton(
-                    new Range(
-                            new Key(
-                                    shard, DOC,
-                                    new Text(URI_MARKER_STR + uri + FAMILY_DELIM_STR + "\0")
-                            ),
-                            new Key(
-                                    shard, DOC,
-                                    new Text(URI_MARKER_STR + uri + FAMILY_DELIM_STR + "\uFFFD")
-                            )
-                    )
-            ));
-
-            int count = 0;
-            Iterator<Map.Entry<Key, Value>> iter = bs.iterator();
-            while (iter.hasNext()) {
-                count++;
-//                iter.next();
-                System.out.println(iter.next().getKey().getColumnQualifier());
-            }
-            System.out.println(count);
-
-            bs.close();
-
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/shard/DateHashModShardValueGeneratorTest.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/shard/DateHashModShardValueGeneratorTest.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/shard/DateHashModShardValueGeneratorTest.java
deleted file mode 100644
index fe27ec7..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/shard/DateHashModShardValueGeneratorTest.java
+++ /dev/null
@@ -1,30 +0,0 @@
-package mvm.mmrts.rdf.partition.shard;
-
-import junit.framework.TestCase;
-
-import java.text.SimpleDateFormat;
-import java.util.Calendar;
-import java.util.Date;
-
-/**
- * Class DateHashModShardValueGeneratorTest
- * Date: Jul 6, 2011
- * Time: 6:35:32 PM
- */
-public class DateHashModShardValueGeneratorTest extends TestCase {
-    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
-    Calendar cal = Calendar.getInstance();
-
-    public void testGenerateShardValue() throws Exception {
-
-        DateHashModShardValueGenerator gen = new DateHashModShardValueGenerator();
-        gen.setBaseMod(100);
-        assertEquals(gen.generateShardValue("subject"), dateFormat.format(cal.getTime()) + "_68");
-    }
-
-    public void testGenerateShardValueNullObject() throws Exception {
-        DateHashModShardValueGenerator gen = new DateHashModShardValueGenerator();
-        gen.setBaseMod(100);
-        assertEquals(gen.generateShardValue(null), dateFormat.format(cal.getTime()));
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/80faf06d/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/utils/RdfIOTest.java
----------------------------------------------------------------------
diff --git a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/utils/RdfIOTest.java b/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/utils/RdfIOTest.java
deleted file mode 100644
index d251485..0000000
--- a/partition/partition.rdf/src/test/java/mvm/mmrts/rdf/partition/utils/RdfIOTest.java
+++ /dev/null
@@ -1,82 +0,0 @@
-package mvm.mmrts.rdf.partition.utils;
-
-import com.google.common.io.ByteStreams;
-import com.google.common.primitives.Bytes;
-import junit.framework.TestCase;
-import org.openrdf.model.Statement;
-import org.openrdf.model.ValueFactory;
-import org.openrdf.model.impl.StatementImpl;
-import org.openrdf.model.impl.ValueFactoryImpl;
-
-import static mvm.mmrts.rdf.partition.utils.RdfIO.*;
-
-/**
- * Class RdfIOTest
- * Date: Jul 6, 2011
- * Time: 12:59:25 PM
- */
-public class RdfIOTest extends TestCase {
-
-    ValueFactory vf = ValueFactoryImpl.getInstance();
-
-    public void testWriteStatementEvent() throws Exception {
-        StatementImpl stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        byte[] bytes = writeStatement(stmt, true);
-    }
-
-    public void testWriteStatementIndex() throws Exception {
-        StatementImpl stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        byte[] bytes = writeStatement(stmt, false);
-    }
-
-    public void testExtraInfoInStmtBytes() throws Exception {
-        StatementImpl stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        byte[] bytes = writeStatement(stmt, true);
-        bytes = Bytes.concat(bytes, "extrainformation".getBytes());
-        Statement readStmt = readStatement(ByteStreams.newDataInput(bytes), ValueFactoryImpl.getInstance());
-        System.out.println(readStmt);
-    }
-
-    public void testReadStatement() throws Exception {
-        StatementImpl stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        byte[] bytes = writeStatement(stmt, true);
-
-        Statement readStmt = readStatement(ByteStreams.newDataInput(bytes), vf);
-        assertEquals(readStmt, stmt);
-
-        //testing blank node
-        stmt = new StatementImpl(vf.createBNode("a12345"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        bytes = writeStatement(stmt, true);
-
-        readStmt = readStatement(ByteStreams.newDataInput(bytes), vf);
-        assertEquals(readStmt, stmt);
-
-        //testing boolean literal datatype
-        stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral(true));
-        bytes = writeStatement(stmt, true);
-
-        readStmt = readStatement(ByteStreams.newDataInput(bytes), vf);
-        assertEquals(readStmt, stmt);
-        
-        //testing boolean literal datatype
-        stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("label", "language"));
-        bytes = writeStatement(stmt, true);
-
-        readStmt = readStatement(ByteStreams.newDataInput(bytes), vf);
-        assertEquals(readStmt, stmt);
-    }
-
-    public void testReadIndexStatement() throws Exception {
-        StatementImpl stmt = new StatementImpl(vf.createURI("urn:namespace#subj"), vf.createURI("urn:namespace#pred"), vf.createLiteral("object"));
-        byte[] bytes = writeStatement(stmt, false);
-
-        Statement readStmt = readStatement(ByteStreams.newDataInput(bytes), vf, false);
-        assertEquals(readStmt, stmt);
-
-        bytes = writeStatement(stmt, true);
-
-        readStmt = readStatement(ByteStreams.newDataInput(bytes), vf, true);
-        assertEquals(readStmt, stmt);
-    }
-
-}


Mime
View raw message