Class ServiceClauseBasedSourcePlannerImpl

java.lang.Object

se.liu.ida.hefquin.engine.queryproc.impl.srcsel.SourcePlannerBase

se.liu.ida.hefquin.engine.queryproc.impl.srcsel.ServiceClauseBasedSourcePlannerImpl

All Implemented Interfaces:

SourcePlanner

Direct Known Subclasses:

ExhaustiveSourcePlannerImpl

public class ServiceClauseBasedSourcePlannerImpl
extends SourcePlannerBase

This implementation of SourcePlanner does not actually perform query decomposition and source selection but simply assumes queries with SERVICE clauses where, for the moment, all of these SERVICE clauses are of the form "SERVICE uri {...}" (i.e., not "SERVICE var {...}"). Therefore, all that this implementation does is to convert the given query pattern into a logical plan.

Constructor Summary

Constructors

Constructor	Description
ServiceClauseBasedSourcePlannerImpl()

Method Summary

Modifier and Type	Method	Description
protected LogicalPlan	createPlan(org.apache.jena.sparql.algebra.Op jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlan(org.apache.jena.sparql.algebra.Op jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForBGP(org.apache.jena.sparql.algebra.op.OpBGP pattern, FederationMember fm)
protected LogicalPlan	createPlanForBGP(org.apache.jena.sparql.core.BasicPattern pattern, FederationMember fm)
protected LogicalPlan	createPlanForBGP(BGP bgp, FederationMember fm)
protected LogicalPlan	createPlanForBind(org.apache.jena.sparql.algebra.op.OpExtend jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForFilter(org.apache.jena.sparql.algebra.op.OpFilter jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForFilter(org.apache.jena.sparql.algebra.op.OpFilter jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForJoin(List<org.apache.jena.sparql.algebra.Op> ops, QueryProcContext ctxt)
protected LogicalPlan	createPlanForJoin(org.apache.jena.sparql.algebra.op.OpJoin jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForJoin(org.apache.jena.sparql.algebra.op.OpJoin jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpConditional jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpConditional jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpLeftJoin jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpLeftJoin jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForOpTable(org.apache.jena.sparql.algebra.op.OpTable opTable)
protected LogicalPlan	createPlanForSequence(org.apache.jena.sparql.algebra.op.OpSequence jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForServicePattern(org.apache.jena.sparql.algebra.op.OpService jenaOp, QueryProcContext ctxt)	This function assumes that the given operator comes from a SERVICE clause that did not have a PARAMS part (or an empty one), and it produces a plan with a request operator as root.
protected LogicalPlan	createPlanForServiceWithParams(OpServiceWithParams jenaOp, LogicalPlan subplan, QueryProcContext ctxt)	This function assumes that the given operator comes from a SERVICE clause that had a nonempty PARAMS part, and it produces a plan with a gpAdd operator as root and the given subplan as input to this root operator.
protected LogicalPlan	createPlanForTriplePattern(org.apache.jena.sparql.algebra.op.OpTriple pattern, FederationMember fm)
protected LogicalPlan	createPlanForUnfold(org.apache.jena.sparql.algebra.op.OpUnfold jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForUnion(org.apache.jena.sparql.algebra.op.OpUnion jenaOp, QueryProcContext ctxt)
protected LogicalPlan	createPlanForUnion(org.apache.jena.sparql.algebra.op.OpUnion jenaOp, FederationMember fm)
protected LogicalPlan	createPlanForValues(org.apache.jena.sparql.algebra.op.OpTable jenaOp, QueryProcContext ctxt)
protected Pair<LogicalPlan,SourcePlanningStats>	createSourceAssignment(org.apache.jena.sparql.algebra.Op jenaOp, QueryProcContext ctxt)
protected LogicalPlan	mergeIntoMultiwayJoin(List<LogicalPlan> subPlans)
protected LogicalPlan	mergeIntoMultiwayJoin(LogicalPlan... subPlans)
protected LogicalPlan	mergeIntoMultiwayLeftJoin(LogicalPlan leftSubPlan, LogicalPlan rightSubPlan)
protected LogicalPlan	mergeIntoMultiwayUnion(LogicalPlan... subPlans)

Methods inherited from class se.liu.ida.hefquin.engine.queryproc.impl.srcsel.SourcePlannerBase

createSourceAssignment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ServiceClauseBasedSourcePlannerImpl

public ServiceClauseBasedSourcePlannerImpl()

Method Details

createSourceAssignment

protected Pair<LogicalPlan,SourcePlanningStats> createSourceAssignment(org.apache.jena.sparql.algebra.Op jenaOp,
 QueryProcContext ctxt)
                                                                throws SourcePlanningException

Specified by:

createSourceAssignment in class SourcePlannerBase

Throws:

SourcePlanningException

createPlan

protected LogicalPlan createPlan(org.apache.jena.sparql.algebra.Op jenaOp,
 QueryProcContext ctxt)

createPlanForSequence

protected LogicalPlan createPlanForSequence(org.apache.jena.sparql.algebra.op.OpSequence jenaOp,
 QueryProcContext ctxt)

createPlanForJoin

protected LogicalPlan createPlanForJoin(org.apache.jena.sparql.algebra.op.OpJoin jenaOp,
 QueryProcContext ctxt)

createPlanForJoin

protected LogicalPlan createPlanForJoin(List<org.apache.jena.sparql.algebra.Op> ops,
 QueryProcContext ctxt)

createPlanForLeftJoin

protected LogicalPlan createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpLeftJoin jenaOp,
 QueryProcContext ctxt)

createPlanForLeftJoin

protected LogicalPlan createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpConditional jenaOp,
 QueryProcContext ctxt)

createPlanForUnion

protected LogicalPlan createPlanForUnion(org.apache.jena.sparql.algebra.op.OpUnion jenaOp,
 QueryProcContext ctxt)

createPlanForFilter

protected LogicalPlan createPlanForFilter(org.apache.jena.sparql.algebra.op.OpFilter jenaOp,
 QueryProcContext ctxt)

createPlanForBind

protected LogicalPlan createPlanForBind(org.apache.jena.sparql.algebra.op.OpExtend jenaOp,
 QueryProcContext ctxt)

createPlanForUnfold

protected LogicalPlan createPlanForUnfold(org.apache.jena.sparql.algebra.op.OpUnfold jenaOp,
 QueryProcContext ctxt)

createPlanForValues

protected LogicalPlan createPlanForValues(org.apache.jena.sparql.algebra.op.OpTable jenaOp,
 QueryProcContext ctxt)

createPlanForServicePattern

protected LogicalPlan createPlanForServicePattern(org.apache.jena.sparql.algebra.op.OpService jenaOp,
 QueryProcContext ctxt)

This function assumes that the given operator comes from a SERVICE clause that did not have a PARAMS part (or an empty one), and it produces a plan with a request operator as root.

createPlanForServiceWithParams

protected LogicalPlan createPlanForServiceWithParams(OpServiceWithParams jenaOp,
 LogicalPlan subplan,
 QueryProcContext ctxt)

This function assumes that the given operator comes from a SERVICE clause that had a nonempty PARAMS part, and it produces a plan with a gpAdd operator as root and the given subplan as input to this root operator.

createPlan

protected LogicalPlan createPlan(org.apache.jena.sparql.algebra.Op jenaOp,
 FederationMember fm)

createPlanForJoin

protected LogicalPlan createPlanForJoin(org.apache.jena.sparql.algebra.op.OpJoin jenaOp,
 FederationMember fm)

createPlanForLeftJoin

protected LogicalPlan createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpLeftJoin jenaOp,
 FederationMember fm)

createPlanForLeftJoin

protected LogicalPlan createPlanForLeftJoin(org.apache.jena.sparql.algebra.op.OpConditional jenaOp,
 FederationMember fm)

createPlanForUnion

protected LogicalPlan createPlanForUnion(org.apache.jena.sparql.algebra.op.OpUnion jenaOp,
 FederationMember fm)

createPlanForFilter

protected LogicalPlan createPlanForFilter(org.apache.jena.sparql.algebra.op.OpFilter jenaOp,
 FederationMember fm)

createPlanForBGP

protected LogicalPlan createPlanForBGP(org.apache.jena.sparql.algebra.op.OpBGP pattern,
 FederationMember fm)

createPlanForBGP

protected LogicalPlan createPlanForBGP(org.apache.jena.sparql.core.BasicPattern pattern,
 FederationMember fm)

createPlanForTriplePattern

protected LogicalPlan createPlanForTriplePattern(org.apache.jena.sparql.algebra.op.OpTriple pattern,
 FederationMember fm)

createPlanForBGP

protected LogicalPlan createPlanForBGP(BGP bgp,
 FederationMember fm)

createPlanForOpTable

protected LogicalPlan createPlanForOpTable(org.apache.jena.sparql.algebra.op.OpTable opTable)

mergeIntoMultiwayJoin

protected LogicalPlan mergeIntoMultiwayJoin(LogicalPlan... subPlans)

mergeIntoMultiwayJoin

protected LogicalPlan mergeIntoMultiwayJoin(List<LogicalPlan> subPlans)

mergeIntoMultiwayLeftJoin

protected LogicalPlan mergeIntoMultiwayLeftJoin(LogicalPlan leftSubPlan,
 LogicalPlan rightSubPlan)

mergeIntoMultiwayUnion

protected LogicalPlan mergeIntoMultiwayUnion(LogicalPlan... subPlans)