@Test public void testSingleIndex2() throws Exception { String q1 = "" + "SELECT ?f ?m ?d ?e ?l ?c " + "{" + " ?f a ?m ." + " ?c a ?l ." + " ?d <uri:talksTo> ?f . " + " ?e <uri:talksTo> ?c . " + " ?m <http: + " ?l <http: + " ?m <uri:talksTo> ?e . " + "}"; String q2 = "" + "SELECT ?u ?s ?t " + "{" + " ?s a ?t ." + " ?t <http: + " ?u <uri:talksTo> ?s . " + "}"; String q3 = "" + "SELECT ?e ?c ?l " + "{" + " ?c a ?l ." + " ?l <http: + " ?e <uri:talksTo> ?c . " + "}"; String q4 = "" + "SELECT ?d ?f ?m " + "{" + " ?f a ?m ." + " ?m <http: + " ?d <uri:talksTo> ?f . " + "}"; SPARQLParser parser = new SPARQLParser(); ParsedQuery pq1 = parser.parseQuery(q1, null); ParsedQuery pq2 = parser.parseQuery(q2, null); ParsedQuery pq3 = parser.parseQuery(q3, null); ParsedQuery pq4 = parser.parseQuery(q4, null); SimpleExternalTupleSet extTup1 = new SimpleExternalTupleSet( (Projection) pq2.getTupleExpr()); SimpleExternalTupleSet extTup2 = new SimpleExternalTupleSet( (Projection) pq3.getTupleExpr()); SimpleExternalTupleSet extTup3 = new SimpleExternalTupleSet( (Projection) pq4.getTupleExpr()); List<ExternalTupleSet> list = new ArrayList<ExternalTupleSet>(); list.add(extTup1); List<StatementPattern> spList = StatementPatternCollector.process(pq1 .getTupleExpr()); List<QueryModelNode> optTupNodes = Lists.newArrayList(); optTupNodes.add(extTup3); optTupNodes.add(spList.get(6)); optTupNodes.add(extTup2); IndexedExecutionPlanGenerator iep = new IndexedExecutionPlanGenerator( pq1.getTupleExpr(), list); Iterator<TupleExpr> plans = new TupleExecutionPlanGenerator() .getPlans(iep.getIndexedTuples()); IndexPlanValidator ipv = new IndexPlanValidator(true); Iterator<TupleExpr> validPlans = ipv.getValidTuples(plans); ThreshholdPlanSelector tps = new ThreshholdPlanSelector( pq1.getTupleExpr()); TupleExpr optimalTup = tps.getThreshholdQueryPlan(validPlans, .4, .7, .1, .2); NodeCollector nc = new NodeCollector(); optimalTup.visit(nc); List<QueryModelNode> qNodes = nc.getNodes(); Assert.assertTrue(qNodes.equals(optTupNodes)); }
@Override public TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight, double commonVarWeight, double extProdWeight) { if (threshhold < 0 || threshhold > 1) { throw new IllegalArgumentException("Threshhold must be between 0 and 1!"); } double minCost = Double.MAX_VALUE; TupleExpr minTup = null; double tempCost = 0; TupleExpr tempTup = null; while (tuples.hasNext()) { tempTup = tuples.next(); tempCost = getCost(tempTup, indexWeight, commonVarWeight, extProdWeight); if (tempCost < minCost) { minCost = tempCost; minTup = tempTup; } if (minCost <= threshhold) { return minTup; } } return minTup; }
ThreshholdPlanSelector implements IndexedQueryPlanSelector { @Override public TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight, double commonVarWeight, double extProdWeight) { if (threshhold < 0 || threshhold > 1) { throw new IllegalArgumentException("Threshhold must be between 0 and 1!"); } double minCost = Double.MAX_VALUE; TupleExpr minTup = null; double tempCost = 0; TupleExpr tempTup = null; while (tuples.hasNext()) { tempTup = tuples.next(); tempCost = getCost(tempTup, indexWeight, commonVarWeight, extProdWeight); if (tempCost < minCost) { minCost = tempCost; minTup = tempTup; } if (minCost <= threshhold) { return minTup; } } return minTup; } }
ThreshholdPlanSelector implements IndexedQueryPlanSelector { @Override public TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight, double commonVarWeight, double extProdWeight) { if (threshhold < 0 || threshhold > 1) { throw new IllegalArgumentException("Threshhold must be between 0 and 1!"); } double minCost = Double.MAX_VALUE; TupleExpr minTup = null; double tempCost = 0; TupleExpr tempTup = null; while (tuples.hasNext()) { tempTup = tuples.next(); tempCost = getCost(tempTup, indexWeight, commonVarWeight, extProdWeight); if (tempCost < minCost) { minCost = tempCost; minTup = tempTup; } if (minCost <= threshhold) { return minTup; } } return minTup; } ThreshholdPlanSelector(TupleExpr query); }
ThreshholdPlanSelector implements IndexedQueryPlanSelector { @Override public TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight, double commonVarWeight, double extProdWeight) { if (threshhold < 0 || threshhold > 1) { throw new IllegalArgumentException("Threshhold must be between 0 and 1!"); } double minCost = Double.MAX_VALUE; TupleExpr minTup = null; double tempCost = 0; TupleExpr tempTup = null; while (tuples.hasNext()) { tempTup = tuples.next(); tempCost = getCost(tempTup, indexWeight, commonVarWeight, extProdWeight); if (tempCost < minCost) { minCost = tempCost; minTup = tempTup; } if (minCost <= threshhold) { return minTup; } } return minTup; } ThreshholdPlanSelector(TupleExpr query); @Override TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight,
            double commonVarWeight, double extProdWeight); double getCost(TupleExpr te, double indexWeight, double commonVarWeight, double dirProdWeight); }
ThreshholdPlanSelector implements IndexedQueryPlanSelector { @Override public TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight, double commonVarWeight, double extProdWeight) { if (threshhold < 0 || threshhold > 1) { throw new IllegalArgumentException("Threshhold must be between 0 and 1!"); } double minCost = Double.MAX_VALUE; TupleExpr minTup = null; double tempCost = 0; TupleExpr tempTup = null; while (tuples.hasNext()) { tempTup = tuples.next(); tempCost = getCost(tempTup, indexWeight, commonVarWeight, extProdWeight); if (tempCost < minCost) { minCost = tempCost; minTup = tempTup; } if (minCost <= threshhold) { return minTup; } } return minTup; } ThreshholdPlanSelector(TupleExpr query); @Override TupleExpr getThreshholdQueryPlan(Iterator<TupleExpr> tuples, double threshhold, double indexWeight,
            double commonVarWeight, double extProdWeight); double getCost(TupleExpr te, double indexWeight, double commonVarWeight, double dirProdWeight);  }