Class DefaultEvaluationStrategy
- java.lang.Object
-
- org.eclipse.rdf4j.query.algebra.evaluation.impl.DefaultEvaluationStrategy
-
- All Implemented Interfaces:
EvaluationStrategy
,FederatedServiceResolver
,FederatedServiceResolverClient
- Direct Known Subclasses:
StrictEvaluationStrategy
public class DefaultEvaluationStrategy extends Object implements EvaluationStrategy, FederatedServiceResolverClient
Default SPARQL 1.1 Query Evaluation strategy, to evaluate oneTupleExpr
on the givenTripleSource
, optionally using the givenDataset
. The behaviour of this strategy can be modified by setting theQueryEvaluationMode
, which determines if the SPARQL query is evaluated usingstrict
compliance orstandard
compliance.- Author:
- Jeen Broekstra, James Leigh, Arjohn Kampman, David Huynh, Andreas Schwarte
-
-
Field Summary
Fields Modifier and Type Field Description protected Dataset
dataset
protected FederatedServiceResolver
serviceResolver
protected TripleSource
tripleSource
-
Constructor Summary
Constructors Constructor Description DefaultEvaluationStrategy(TripleSource tripleSource, FederatedServiceResolver serviceResolver)
DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver)
DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics)
DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics, boolean trackResultSize)
DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics, boolean trackResultSize, TupleFunctionRegistry tupleFunctionRegistry)
-
Method Summary
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.query.algebra.evaluation.EvaluationStrategy
isTrackResultSize
-
-
-
-
Field Detail
-
tripleSource
protected final TripleSource tripleSource
-
dataset
protected final Dataset dataset
-
serviceResolver
protected FederatedServiceResolver serviceResolver
-
-
Constructor Detail
-
DefaultEvaluationStrategy
public DefaultEvaluationStrategy(TripleSource tripleSource, FederatedServiceResolver serviceResolver)
-
DefaultEvaluationStrategy
public DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver)
-
DefaultEvaluationStrategy
public DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics)
-
DefaultEvaluationStrategy
public DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics, boolean trackResultSize)
-
DefaultEvaluationStrategy
public DefaultEvaluationStrategy(TripleSource tripleSource, Dataset dataset, FederatedServiceResolver serviceResolver, long iterationCacheSyncTreshold, EvaluationStatistics evaluationStatistics, boolean trackResultSize, TupleFunctionRegistry tupleFunctionRegistry)
-
-
Method Detail
-
evaluate
protected static CloseableIteration<BindingSet> evaluate(TupleFunction func, List<Var> resultVars, BindingSet bindings, ValueFactory valueFactory, Value... argValues) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
setFederatedServiceResolver
public void setFederatedServiceResolver(FederatedServiceResolver resolver)
Description copied from interface:FederatedServiceResolverClient
Sets theFederatedServiceResolver
to use for this client.- Specified by:
setFederatedServiceResolver
in interfaceFederatedServiceResolverClient
- Parameters:
resolver
- The resolver to use.
-
getFederatedServiceResolver
public FederatedServiceResolver getFederatedServiceResolver()
Description copied from interface:FederatedServiceResolverClient
Gets theFederatedServiceResolver
used by this client.- Specified by:
getFederatedServiceResolver
in interfaceFederatedServiceResolverClient
-
getService
public FederatedService getService(String serviceUrl) throws QueryEvaluationException
Description copied from interface:EvaluationStrategy
Retrieve theFederatedService
registered for serviceUrl. If there is no service registered for serviceUrl, a newSPARQLFederatedService
is created and registered.- Specified by:
getService
in interfaceEvaluationStrategy
- Specified by:
getService
in interfaceFederatedServiceResolver
- Parameters:
serviceUrl
- URL of the service.- Returns:
- the
FederatedService
registered for the serviceUrl. - Throws:
QueryEvaluationException
- If there was an exception generated while retrieving the service.- See Also:
FederatedServiceResolver.getService(java.lang.String)
-
setOptimizerPipeline
public void setOptimizerPipeline(QueryOptimizerPipeline pipeline)
Description copied from interface:EvaluationStrategy
Set theQueryOptimizerPipeline
to use for optimizing any incoming queries.- Specified by:
setOptimizerPipeline
in interfaceEvaluationStrategy
- Parameters:
pipeline
- theQueryOptimizerPipeline
.- See Also:
EvaluationStrategy.optimize(TupleExpr, EvaluationStatistics, BindingSet)
-
optimize
public TupleExpr optimize(TupleExpr expr, EvaluationStatistics evaluationStatistics, BindingSet bindings)
Execute theQueryOptimizerPipeline
on the givenTupleExpr
to optimize its execution plan.- Specified by:
optimize
in interfaceEvaluationStrategy
- Parameters:
expr
- theTupleExpr
to optimize.evaluationStatistics
- this param is ignored!bindings
- a-priori bindings supplied for the query, which can potentially be inlined.- Returns:
- the optimized
TupleExpr
. - Since:
- 3.0
- See Also:
setOptimizerPipeline(QueryOptimizerPipeline)
-
evaluate
@Deprecated(forRemoval=true) public CloseableIteration<BindingSet> evaluate(TupleExpr expr, BindingSet bindings) throws QueryEvaluationException
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:EvaluationStrategy
Evaluates the tuple expression against the supplied triple source with the specified set of variable bindings as input.- Specified by:
evaluate
in interfaceEvaluationStrategy
- Parameters:
expr
- The Tuple Expression to evaluatebindings
- The variables bindings to use for evaluating the expression, if applicable.- Returns:
- A closeable iterator over the variable binding sets that match the tuple expression.
- Throws:
QueryEvaluationException
-
precompile
public QueryEvaluationStep precompile(TupleExpr expr)
Description copied from interface:EvaluationStrategy
Prepare a QueryEvaluationStep that tries to do as much work once per query avoiding repeated calls to the same code as much as possible. This depends on java invoke dynamic for performance.- Specified by:
precompile
in interfaceEvaluationStrategy
- Parameters:
expr
- that is to be evaluated later- Returns:
- a QueryEvaluationStep that may avoid doing repeating the same work over and over.
-
precompile
public QueryEvaluationStep precompile(TupleExpr expr, QueryEvaluationContext context)
- Specified by:
precompile
in interfaceEvaluationStrategy
-
prepare
protected QueryEvaluationStep prepare(ArbitraryLengthPath alp, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(ZeroLengthPath zlp, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Difference node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Group node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Intersection node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Join node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(LeftJoin node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(MultiProjection node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Projection node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(QueryRoot node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(StatementPattern node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Union node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Slice node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Extension node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Service service, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Filter node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Order node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(BindingSetAssignment node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(DescribeOperator node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Distinct node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(Reduced node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(TupleFunctionCall expr, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
getVarValue
public static Value getVarValue(Var var, BindingSet bindings)
-
prepare
protected QueryEvaluationStep prepare(UnaryTupleOperator expr, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(BinaryTupleOperator expr, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(SingletonSet singletonSet, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryEvaluationStep prepare(EmptySet emptySet, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
precompile
public QueryValueEvaluationStep precompile(ValueExpr expr, QueryEvaluationContext context) throws QueryEvaluationException
- Specified by:
precompile
in interfaceEvaluationStrategy
- Throws:
QueryEvaluationException
-
evaluate
@Deprecated(forRemoval=true) public Value evaluate(ValueExpr expr, BindingSet bindings) throws QueryEvaluationException
Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:EvaluationStrategy
Gets the value of this expression.- Specified by:
evaluate
in interfaceEvaluationStrategy
bindings
- The variables bindings to use for evaluating the expression, if applicable.- Returns:
- The Value that this expression evaluates to, or null if the expression could not be evaluated.
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Var var, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(ValueConstant valueConstant, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(BNodeGenerator node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Bound node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Str node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Label node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Lang node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(Datatype node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(Namespace node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(LocalName node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IsResource node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IsURI node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IsBNode node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IsLiteral node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IsNumeric node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(IRIFunction node, QueryEvaluationContext context)
-
evaluate
@Deprecated(forRemoval=true) public Value evaluate(Regex node, BindingSet bindings) throws QueryEvaluationException
Deprecated, for removal: This API element is subject to removal in a future version.Determines whether the two operands match according to theregex
operator.- Returns:
- true if the operands match according to the regex operator, false otherwise.
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Regex node, QueryEvaluationContext context) throws QueryEvaluationException
Determines whether the two operands match according to theregex
operator.- Returns:
- true if the operands match according to the regex operator, false otherwise.
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(LangMatches node, QueryEvaluationContext context)
-
prepare
public QueryValueEvaluationStep prepare(FunctionCall node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Or node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Not node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(Now node, QueryEvaluationContext context)
During the execution of a single query NOW() should always return the same result and is in practical terms a constant during evaluation.- Parameters:
node
- that represent the NOW() functioncontext
- that holds the shared now() of the query invocation- Returns:
- a constant value evaluation step
-
prepare
protected QueryValueEvaluationStep prepare(SameTerm node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(Coalesce node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Compare node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(MathExpr node, QueryEvaluationContext context)
-
prepare
protected QueryValueEvaluationStep prepare(If node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(In node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(ListMemberOperator node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(CompareAny node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(CompareAll node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
prepare
protected QueryValueEvaluationStep prepare(Exists node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
isTrue
public boolean isTrue(ValueExpr expr, BindingSet bindings) throws QueryEvaluationException
Description copied from interface:EvaluationStrategy
Evaluates the boolean expression on the supplied TripleSource object.- Specified by:
isTrue
in interfaceEvaluationStrategy
bindings
- The variables bindings to use for evaluating the expression, if applicable.- Returns:
- The result of the evaluation.
- Throws:
ValueExprEvaluationException
- If the value expression could not be evaluated, for example when comparing two incompatible operands. When thrown, the result of the boolean expression is neither true nor false , but unknown.QueryEvaluationException
-
isTrue
public boolean isTrue(QueryValueEvaluationStep expr, BindingSet bindings) throws QueryEvaluationException
- Specified by:
isTrue
in interfaceEvaluationStrategy
- Throws:
QueryEvaluationException
-
isReducedOrDistinct
protected boolean isReducedOrDistinct(QueryModelNode node)
-
getLimit
protected long getLimit(QueryModelNode node)
Returns the limit of the current variable bindings before any further projection.
-
prepare
protected QueryValueEvaluationStep prepare(ValueExprTripleRef node, QueryEvaluationContext context) throws QueryEvaluationException
- Throws:
QueryEvaluationException
-
evaluate
public CloseableIteration<BindingSet> evaluate(TripleRef ref, BindingSet bindings)
evaluates a TripleRef node returning bindingsets from the matched Triple nodes in the dataset (or explore standard reification)- Parameters:
ref
- to evaluatebindings
- with the solutions- Returns:
- iteration over the solutions
-
prepare
protected QueryEvaluationStep prepare(TripleRef ref, QueryEvaluationContext context)
-
setTrackResultSize
public void setTrackResultSize(boolean trackResultSize)
Description copied from interface:EvaluationStrategy
Enable or disable results size tracking for the query plan. Useful to determine which parts of a query plan generated the most data.- Specified by:
setTrackResultSize
in interfaceEvaluationStrategy
- Parameters:
trackResultSize
- true to enable tracking.
-
setTrackTime
public void setTrackTime(boolean trackTime)
Description copied from interface:EvaluationStrategy
Enable or disable time tracking for the query plan. Useful to determine which parts of a query plan take the most time to evaluate.- Specified by:
setTrackTime
in interfaceEvaluationStrategy
- Parameters:
trackTime
- true to enable tracking.
-
supplyBinaryValueEvaluation
protected QueryValueEvaluationStep supplyBinaryValueEvaluation(BinaryValueOperator node, BiFunction<Value,Value,Value> operation, QueryEvaluationContext context)
Supply a QueryValueEvalationStep that will invoke the function (operator passed in). It will try to optimise constant argument to be called only once per query run,- Parameters:
node
- the node to evaluateoperation
- the function that wraps the operator.context
- in which the query is running.- Returns:
- a potential constant evaluation step.
-
supplyUnaryValueEvaluation
protected QueryValueEvaluationStep supplyUnaryValueEvaluation(UnaryValueOperator node, Function<Value,Value> operation, QueryEvaluationContext context)
Return a QueryEvaluationStep that applies constant propegation.- Parameters:
node
- that will be evaluated/preparedoperation
- the task to be donecontext
- in which the evaluation takes place- Returns:
- a potentially constant step
-
getQueryEvaluationMode
public QueryEvaluationMode getQueryEvaluationMode()
- Specified by:
getQueryEvaluationMode
in interfaceEvaluationStrategy
- Returns:
- the queryEvaluationMode
-
setQueryEvaluationMode
public void setQueryEvaluationMode(QueryEvaluationMode queryEvaluationMode)
- Specified by:
setQueryEvaluationMode
in interfaceEvaluationStrategy
- Parameters:
queryEvaluationMode
- the queryEvaluationMode to set
-
getCollectionFactory
public Supplier<CollectionFactory> getCollectionFactory()
- Specified by:
getCollectionFactory
in interfaceEvaluationStrategy
-
setCollectionFactory
public void setCollectionFactory(Supplier<CollectionFactory> cf)
Description copied from interface:EvaluationStrategy
Set the collection factory that will create the collections to use during query evaluaton.- Specified by:
setCollectionFactory
in interfaceEvaluationStrategy
- Parameters:
cf
- CollectionFactory that should be used during future query evaluations
-
-