Class FederationEvaluationStrategy

java.lang.Object

org.eclipse.rdf4j.query.algebra.evaluation.impl.DefaultEvaluationStrategy

org.eclipse.rdf4j.query.algebra.evaluation.impl.StrictEvaluationStrategy

org.eclipse.rdf4j.federated.evaluation.FederationEvaluationStrategy

All Implemented Interfaces:

EvaluationStrategy, FederatedServiceResolver, FederatedServiceResolverClient

public class FederationEvaluationStrategy
extends StrictEvaluationStrategy

Implementation of a federation evaluation strategy which provides some special optimizations for SPARQL (remote) endpoints. The most important optimization is to used prepared SPARQL Queries that are already created using Strings.

Joins are executed using ControlledWorkerBindJoin.

This implementation uses the SPARQL 1.1 VALUES operator for the bound-join evaluation

s

Author:

Andreas Schwarte

Field Summary

Fields

Modifier and Type	Field	Description
protected SourceSelectionCache	cache
protected Executor	executor
protected FederationContext	federationContext

Fields inherited from class DefaultEvaluationStrategy

dataset, serviceResolver, tripleSource

Modifier and Type	Field	Description
protected final Dataset	dataset
protected FederatedServiceResolver	serviceResolver
protected final TripleSource	tripleSource

Constructor Summary

Constructors

Constructor	Description
FederationEvaluationStrategy(FederationContext federationContext)

Method Summary

Modifier and Type	Method	Description
Value	evaluate(ConjunctiveFilterExpr node, BindingSet bindings)
Value	evaluate(FilterExpr node, BindingSet bindings)
CloseableIteration<BindingSet>	evaluate(DescribeOperator operator, BindingSet bindings)
CloseableIteration<BindingSet>	evaluate(TupleExpr expr, BindingSet bindings)	Deprecated, for removal: This API element is subject to removal in a future version.
Value	evaluate(ValueExpr expr, BindingSet bindings)	Deprecated, for removal: This API element is subject to removal in a future version.
protected CloseableIteration<BindingSet>	evaluateArbitrayLengthPath(FedXArbitraryLengthPath alp, BindingSet bindings)
protected CloseableIteration<BindingSet>	evaluateAtStatementSources(Object preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
protected CloseableIteration<BindingSet>	evaluateAtStatementSources(String preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
protected CloseableIteration<BindingSet>	evaluateAtStatementSources(TupleExpr preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
CloseableIteration<BindingSet>	evaluateBoundJoinStatementPattern(StatementTupleExpr stmt, List<BindingSet> bindings)	Evaluate a bound join at the relevant endpoint, i.e. i.e. for a group of bindings retrieve results for the bound statement from the relevant endpoints
CloseableIteration<BindingSet>	evaluateExclusiveGroup(ExclusiveGroup group, BindingSet bindings)
protected CloseableIteration<BindingSet>	evaluateExclusiveTupleExpr(ExclusiveTupleExpr expr, BindingSet bindings)	Evaluate an ExclusiveTupleExpr.
CloseableIteration<BindingSet>	evaluateLeftBoundJoinStatementPattern(StatementTupleExpr stmt, List<BindingSet> bindings)	Evaluate the left bind join for the given StatementTupleExpr and bindings at the relevant endpoints.
protected CloseableIteration<BindingSet>	evaluateLeftJoin(FedXLeftJoin leftJoin, BindingSet bindings)	Evaluate a FedXLeftJoin (i.e. an OPTIONAL clause)
CloseableIteration<BindingSet>	evaluateNaryUnion(NUnion union, BindingSet bindings)
CloseableIteration<BindingSet>	evaluateNJoin(NJoin join, BindingSet bindings)
CloseableIteration<BindingSet>	evaluateService(FedXService service, List<BindingSet> bindings)	Evaluate a SERVICE using vectored evaluation, taking the provided bindings as input.
CloseableIteration<BindingSet>	evaluateService(FedXService service, BindingSet bindings)
CloseableIteration<BindingSet>	evaluateSingleSourceQuery(SingleSourceQuery query, BindingSet bindings)
protected CloseableIteration<BindingSet>	evaluateZeroLengthPath(FedXZeroLengthPath zlp, BindingSet bindings)
CloseableIteration<BindingSet>	executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo)	Execute the join in a separate thread using some join executor.
protected CloseableIteration<BindingSet>	executeLeftJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet> leftIter, LeftJoin leftJoin, BindingSet bindings, QueryInfo queryInfo)	Execute the left join in a separate thread using some join executor.
protected List<Endpoint>	getAccessibleFederationMembers(QueryInfo queryInfo)	Returns the accessible federation members in the context of the query.
protected List<Endpoint>	getMembersFromContext(FederationEvaluationStatistics evaluationStatisticss)	Returns the federation members that are active in the current federation.
CloseableIteration<Statement>	getStatements(QueryInfo queryInfo, Resource subj, IRI pred, Value obj, Resource... contexts)	Retrieve the statements matching the provided subject, predicate and object value from the federation members.
boolean	hasStatements(QueryInfo queryInfo, Resource subj, IRI pred, Value obj, Resource... contexts)	Returns true if the federation has statements
TupleExpr	optimize(TupleExpr expr, EvaluationStatistics evaluationStatistics, BindingSet bindings)	Execute the QueryOptimizerPipeline on the given TupleExpr to optimize its execution plan.
protected void	optimizeExclusiveExpressions(TupleExpr query, QueryInfo queryInfo, GenericInfoOptimizer info)	Optimize ExclusiveTupleExpr, e.g. restructure the exclusive parts of the query AST.
protected void	optimizeJoinOrder(TupleExpr query, QueryInfo queryInfo, GenericInfoOptimizer info)
protected Set<Endpoint>	performSourceSelection(List<Endpoint> members, SourceSelectionCache cache, QueryInfo queryInfo, GenericInfoOptimizer info)	Perform source selection for all statements of the query.
protected Set<Endpoint>	performSourceSelection(FedXArbitraryLengthPath pathExpr, StatementPattern stmt, List<Endpoint> members, SourceSelectionCache cache, QueryInfo queryInfo)	Perform source selection on the statement pattern representing the path expression.
QueryEvaluationStep	precompile(TupleExpr expr, QueryEvaluationContext context)
QueryValueEvaluationStep	precompile(ValueExpr expr, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(ConjunctiveFilterExpr node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(FedXArbitraryLengthPath alp, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(FedXZeroLengthPath zlp, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(FilterExpr node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(DescribeOperator operator, QueryEvaluationContext context)
protected QueryEvaluationStep	prepareExclusiveTupleExpr(ExclusiveTupleExpr expr, QueryEvaluationContext context)
protected QueryEvaluationStep	prepareLeftJoin(FedXLeftJoin leftJoin, QueryEvaluationContext context)
QueryEvaluationStep	prepareNaryUnion(NUnion union, QueryEvaluationContext context)
protected QueryEvaluationStep	prepareNJoin(NJoin join, QueryEvaluationContext context)
protected boolean	propagateServices(List<Service> serviceNodes)	Whether to propagate a SingleSourceQuery containing SERVICE clauses.

Methods inherited from class DefaultEvaluationStrategy

evaluate, evaluate, evaluate, getCollectionFactory, getFederatedServiceResolver, getLimit, getQueryEvaluationMode, getService, getVarValue, isReducedOrDistinct, isTrackResultSize, isTrackTime, isTrue, isTrue, precompile, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, prepare, setCollectionFactory, setFederatedServiceResolver, setOptimizerPipeline, setQueryEvaluationMode, setTrackResultSize, setTrackTime, supplyBinaryValueEvaluation, supplyUnaryValueEvaluation

Modifier and Type	Method	Description
protected static CloseableIteration<BindingSet>	evaluate(TupleFunction func, List<Var> resultVars, BindingSet bindings, ValueFactory valueFactory, Value... argValues)
Value	evaluate(Regex node, BindingSet bindings)	Deprecated, for removal: This API element is subject to removal in a future version.
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)
Supplier<CollectionFactory>	getCollectionFactory()
FederatedServiceResolver	getFederatedServiceResolver()	Gets the FederatedServiceResolver used by this client.
protected long	getLimit(QueryModelNode node)	Returns the limit of the current variable bindings before any further projection.
QueryEvaluationMode	getQueryEvaluationMode()
FederatedService	getService(String serviceUrl)	Retrieve the FederatedService registered for serviceUrl.
static Value	getVarValue(Var var, BindingSet bindings)
protected boolean	isReducedOrDistinct(QueryModelNode node)
boolean	isTrackResultSize()	Enable or disable results size tracking for the query plan.
boolean	isTrackTime()	Enable or disable time tracking for the query plan.
boolean	isTrue(QueryValueEvaluationStep expr, BindingSet bindings)
boolean	isTrue(ValueExpr expr, BindingSet bindings)	Evaluates the boolean expression on the supplied TripleSource object.
QueryEvaluationStep	precompile(TupleExpr expr)	Prepare a QueryEvaluationStep that tries to do as much work once per query avoiding repeated calls to the same code as much as possible.
protected QueryEvaluationStep	prepare(ArbitraryLengthPath alp, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(BinaryTupleOperator expr, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(BindingSetAssignment node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(BNodeGenerator node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Bound node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Coalesce node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(CompareAll node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(CompareAny node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Compare node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Datatype node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Difference node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Distinct node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(EmptySet emptySet, QueryEvaluationContext context)
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.
protected QueryValueEvaluationStep	prepare(Exists node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Extension node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Filter node, QueryEvaluationContext context)
QueryValueEvaluationStep	prepare(FunctionCall node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Group node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(If node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(In node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Intersection node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IRIFunction node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IsBNode node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IsLiteral node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IsNumeric node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IsResource node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(IsURI node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Join node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Label node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(LangMatches node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Lang node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(LeftJoin node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(ListMemberOperator node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(LocalName node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(MathExpr node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(MultiProjection node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Namespace node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Not node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Order node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Or node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Projection node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(QueryRoot node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Reduced node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Regex node, QueryEvaluationContext context)	Determines whether the two operands match according to the regex operator.
protected QueryValueEvaluationStep	prepare(SameTerm node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Service service, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(SingletonSet singletonSet, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Slice node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(StatementPattern node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Str node, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(TripleRef ref, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(TupleFunctionCall expr, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(UnaryTupleOperator expr, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(Union node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(ValueConstant valueConstant, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(ValueExprTripleRef node, QueryEvaluationContext context)
protected QueryValueEvaluationStep	prepare(Var var, QueryEvaluationContext context)
protected QueryEvaluationStep	prepare(ZeroLengthPath zlp, QueryEvaluationContext context)
void	setCollectionFactory(Supplier<CollectionFactory> cf)	Set the collection factory that will create the collections to use during query evaluaton.
void	setFederatedServiceResolver(FederatedServiceResolver resolver)	Sets the FederatedServiceResolver to use for this client.
void	setOptimizerPipeline(QueryOptimizerPipeline pipeline)	Set the QueryOptimizerPipeline to use for optimizing any incoming queries.
void	setQueryEvaluationMode(QueryEvaluationMode queryEvaluationMode)
void	setTrackResultSize(boolean trackResultSize)	Enable or disable results size tracking for the query plan.
void	setTrackTime(boolean trackTime)	Enable or disable time tracking for the query plan.
protected QueryValueEvaluationStep	supplyBinaryValueEvaluation(BinaryValueOperator node, BiFunction<Value,Value,Value> operation, QueryEvaluationContext context)	Supply a QueryValueEvalationStep that will invoke the function (operator passed in).
protected QueryValueEvaluationStep	supplyUnaryValueEvaluation(UnaryValueOperator node, Function<Value,Value> operation, QueryEvaluationContext context)	Return a QueryEvaluationStep that applies constant propegation.

Methods inherited from class Object

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

Field Details

executor

protected Executor executor

cache

protected SourceSelectionCache cache

federationContext

protected FederationContext federationContext

Constructor Details

FederationEvaluationStrategy

public FederationEvaluationStrategy(FederationContext federationContext)

Method Details

optimize

public TupleExpr optimize(TupleExpr expr,
 EvaluationStatistics evaluationStatistics,
 BindingSet bindings)

Description copied from class: DefaultEvaluationStrategy

Execute the QueryOptimizerPipeline on the given TupleExpr to optimize its execution plan.

Specified by:

optimize in interface EvaluationStrategy

Overrides:

optimize in class DefaultEvaluationStrategy

Parameters:

expr - the TupleExpr to optimize.

evaluationStatistics - this param is ignored!

bindings - a-priori bindings supplied for the query, which can potentially be inlined.

Returns:

the optimized TupleExpr.

See Also:

• DefaultEvaluationStrategy.setOptimizerPipeline(QueryOptimizerPipeline)

getMembersFromContext

protected List<Endpoint> getMembersFromContext(FederationEvaluationStatistics evaluationStatisticss)

Returns the federation members that are active in the current federation. By default it is all federation members. If the passed Dataset is a FedXDataset, the defined FedXDataset.getEndpoints() are used.

Parameters:

evaluationStatisticss - to keep the current query context

Returns:

performSourceSelection

protected Set<Endpoint> performSourceSelection(List<Endpoint> members,
 SourceSelectionCache cache,
 QueryInfo queryInfo,
 GenericInfoOptimizer info)

Perform source selection for all statements of the query. As a result of this method all statement nodes are annotated with their relevant sources.

Parameters:

members -

cache -

queryInfo -

info -

Returns:

the set of relevant endpoints for the entire query

performSourceSelection

protected Set<Endpoint> performSourceSelection(FedXArbitraryLengthPath pathExpr,
 StatementPattern stmt,
 List<Endpoint> members,
 SourceSelectionCache cache,
 QueryInfo queryInfo)

Perform source selection on the statement pattern representing the path expression. Source selection must be a subset of the provided members. The implementation expects to replace the statement, e.g. with StatementSourcePattern, ExclusiveStatement or EmptyStatementPattern

Parameters:

pathExpr -

stmt -

members -

cache -

queryInfo -

Returns:

identified relevant members

optimizeJoinOrder

protected void optimizeJoinOrder(TupleExpr query,
 QueryInfo queryInfo,
 GenericInfoOptimizer info)

propagateServices

protected boolean propagateServices(List<Service> serviceNodes)

Whether to propagate a SingleSourceQuery containing SERVICE clauses. By default, the query is always evaluated within the FedX engine if it contains a SERVICE clause.

Customized implementation may propagate a SingleSourceQuery including the SERVICE clause (e.g. for Wikidata the Label service can only be accessed in the wikidata endpoint.

Parameters:

serviceNodes -

Returns:

if true, a SingleSourceQuery containing SERVICE clauses is propagated as-is

optimizeExclusiveExpressions

protected void optimizeExclusiveExpressions(TupleExpr query,
 QueryInfo queryInfo,
 GenericInfoOptimizer info)

Optimize ExclusiveTupleExpr, e.g. restructure the exclusive parts of the query AST.

Parameters:

query -

queryInfo -

info -

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 interface EvaluationStrategy

Overrides:

evaluate in class DefaultEvaluationStrategy

Parameters:

expr - The Tuple Expression to evaluate

bindings - 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,
 QueryEvaluationContext context)
                               throws QueryEvaluationException

Specified by:

precompile in interface EvaluationStrategy

Overrides:

precompile in class DefaultEvaluationStrategy

Throws:

QueryEvaluationException

getStatements

public CloseableIteration<Statement> getStatements(QueryInfo queryInfo,
 Resource subj,
 IRI pred,
 Value obj,
 Resource... contexts)
                                            throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Retrieve the statements matching the provided subject, predicate and object value from the federation members.

For a bound statement, i.e. a statement with no free variables, the statement itself is returned if some member has this statement, an empty iteration otherwise.

If the statement has free variables, i.e. one of the provided arguments in null, the union of results from relevant statement sources is constructed.

Parameters:

subj -

pred -

obj -

contexts -

Returns:

the statement iteration

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

hasStatements

public boolean hasStatements(QueryInfo queryInfo,
 Resource subj,
 IRI pred,
 Value obj,
 Resource... contexts)
                      throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Returns true if the federation has statements

Parameters:

queryInfo - information about the query

subj - the subject or null

pred - the predicate or null

obj - the object or null

contexts - optional list of contexts

Returns:

the statement iteration

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

getAccessibleFederationMembers

@Experimental
protected List<Endpoint> getAccessibleFederationMembers(QueryInfo queryInfo)

Returns the accessible federation members in the context of the query. By default this is all federation members.

Specialized implementations of the FederationEvaluationStrategy may override and define custom behavior (e.g., to support resilience).

Parameters:

queryInfo -

Returns:

evaluateService

public CloseableIteration<BindingSet> evaluateService(FedXService service,
 BindingSet bindings)
                                               throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateSingleSourceQuery

public CloseableIteration<BindingSet> evaluateSingleSourceQuery(SingleSourceQuery query,
 BindingSet bindings)
                                                         throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateNJoin

public CloseableIteration<BindingSet> evaluateNJoin(NJoin join,
 BindingSet bindings)
                                             throws QueryEvaluationException

Throws:

QueryEvaluationException

prepareNJoin

protected QueryEvaluationStep prepareNJoin(NJoin join,
 QueryEvaluationContext context)
                                    throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateArbitrayLengthPath

protected CloseableIteration<BindingSet> evaluateArbitrayLengthPath(FedXArbitraryLengthPath alp,
 BindingSet bindings)
                                                             throws QueryEvaluationException

Throws:

QueryEvaluationException

prepare

protected QueryEvaluationStep prepare(FedXArbitraryLengthPath alp,
 QueryEvaluationContext context)
                               throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateZeroLengthPath

protected CloseableIteration<BindingSet> evaluateZeroLengthPath(FedXZeroLengthPath zlp,
 BindingSet bindings)
                                                         throws QueryEvaluationException

Throws:

QueryEvaluationException

prepare

protected QueryEvaluationStep prepare(FedXZeroLengthPath zlp,
 QueryEvaluationContext context)
                               throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateLeftJoin

protected CloseableIteration<BindingSet> evaluateLeftJoin(FedXLeftJoin leftJoin,
 BindingSet bindings)
                                                   throws QueryEvaluationException

Evaluate a FedXLeftJoin (i.e. an OPTIONAL clause)

Parameters:

leftJoin -

bindings -

Returns:

the resulting iteration

Throws:

QueryEvaluationException

See Also:

• DefaultEvaluationStrategy.evaluate(org.eclipse.rdf4j.query.algebra.LeftJoin, BindingSet)

prepareLeftJoin

protected QueryEvaluationStep prepareLeftJoin(FedXLeftJoin leftJoin,
 QueryEvaluationContext context)
                                       throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateNaryUnion

public CloseableIteration<BindingSet> evaluateNaryUnion(NUnion union,
 BindingSet bindings)
                                                 throws QueryEvaluationException

Throws:

QueryEvaluationException

prepareNaryUnion

public QueryEvaluationStep prepareNaryUnion(NUnion union,
 QueryEvaluationContext context)
                                     throws QueryEvaluationException

Throws:

QueryEvaluationException

executeJoin

public CloseableIteration<BindingSet> executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler,
 CloseableIteration<BindingSet> leftIter,
 TupleExpr rightArg,
 Set<String> joinVars,
 BindingSet bindings,
 QueryInfo queryInfo)
                                           throws QueryEvaluationException

Execute the join in a separate thread using some join executor. Join executors are for instance:

• ControlledWorkerJoin
• ControlledWorkerBindJoin

For endpoint federation use controlled worker bound join, for local federation use controlled worker join. The other operators are there for completeness. Use executor to execute the join (it is a runnable).

Parameters:

joinScheduler -

leftIter -

rightArg -

bindings -

joinVariables -

Returns:

the result

Throws:

QueryEvaluationException

executeLeftJoin

protected CloseableIteration<BindingSet> executeLeftJoin(ControlledWorkerScheduler<BindingSet> joinScheduler,
 CloseableIteration<BindingSet> leftIter,
 LeftJoin leftJoin,
 BindingSet bindings,
 QueryInfo queryInfo)
                                                  throws QueryEvaluationException

Execute the left join in a separate thread using some join executor.

Parameters:

joinScheduler -

leftIter -

leftJoin -

bindings -

Returns:

the result

Throws:

QueryEvaluationException

evaluateExclusiveGroup

public CloseableIteration<BindingSet> evaluateExclusiveGroup(ExclusiveGroup group,
 BindingSet bindings)
                                                      throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

evaluateExclusiveTupleExpr

protected CloseableIteration<BindingSet> evaluateExclusiveTupleExpr(ExclusiveTupleExpr expr,
 BindingSet bindings)
                                                             throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Evaluate an ExclusiveTupleExpr. The default implementation converts the given expression to a SELECT query string and evaluates it at the source.

Parameters:

expr -

bindings -

Returns:

the result

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

prepareExclusiveTupleExpr

protected QueryEvaluationStep prepareExclusiveTupleExpr(ExclusiveTupleExpr expr,
 QueryEvaluationContext context)
                                                 throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

evaluateBoundJoinStatementPattern

public CloseableIteration<BindingSet> evaluateBoundJoinStatementPattern(StatementTupleExpr stmt,
 List<BindingSet> bindings)
                                                                 throws QueryEvaluationException

Evaluate a bound join at the relevant endpoint, i.e. i.e. for a group of bindings retrieve results for the bound statement from the relevant endpoints

Parameters:

stmt -

bindings -

Returns:

the result iteration

Throws:

QueryEvaluationException

evaluateLeftBoundJoinStatementPattern

public CloseableIteration<BindingSet> evaluateLeftBoundJoinStatementPattern(StatementTupleExpr stmt,
 List<BindingSet> bindings)
                                                                     throws QueryEvaluationException

Evaluate the left bind join for the given StatementTupleExpr and bindings at the relevant endpoints.

Parameters:

stmt -

bindings -

Returns:

the result iteration

Throws:

QueryEvaluationException

evaluateService

public CloseableIteration<BindingSet> evaluateService(FedXService service,
 List<BindingSet> bindings)
                                               throws QueryEvaluationException

Evaluate a SERVICE using vectored evaluation, taking the provided bindings as input. See ControlledWorkerBindJoin and FedXConfig.getEnableServiceAsBoundJoin()

Parameters:

service -

bindings -

Returns:

the result iteration

Throws:

QueryEvaluationException

evaluate

@Deprecated(forRemoval=true)
public Value evaluate(ValueExpr expr,
 BindingSet bindings)
               throws ValueExprEvaluationException,
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 interface EvaluationStrategy

Overrides:

evaluate in class DefaultEvaluationStrategy

Parameters:

expr -

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:

ValueExprEvaluationException

QueryEvaluationException

precompile

public QueryValueEvaluationStep precompile(ValueExpr expr,
 QueryEvaluationContext context)
                                    throws ValueExprEvaluationException,
QueryEvaluationException

Specified by:

precompile in interface EvaluationStrategy

Overrides:

precompile in class DefaultEvaluationStrategy

Throws:

ValueExprEvaluationException

QueryEvaluationException

evaluate

public Value evaluate(FilterExpr node,
 BindingSet bindings)
               throws ValueExprEvaluationException,
QueryEvaluationException

Throws:

ValueExprEvaluationException

QueryEvaluationException

prepare

protected QueryValueEvaluationStep prepare(FilterExpr node,
 QueryEvaluationContext context)
                                    throws ValueExprEvaluationException,
QueryEvaluationException

Throws:

ValueExprEvaluationException

QueryEvaluationException

evaluate

public Value evaluate(ConjunctiveFilterExpr node,
 BindingSet bindings)
               throws ValueExprEvaluationException,
QueryEvaluationException

Throws:

ValueExprEvaluationException

QueryEvaluationException

prepare

protected QueryValueEvaluationStep prepare(ConjunctiveFilterExpr node,
 QueryEvaluationContext context)
                                    throws ValueExprEvaluationException,
QueryEvaluationException

Throws:

ValueExprEvaluationException

QueryEvaluationException

evaluate

public CloseableIteration<BindingSet> evaluate(DescribeOperator operator,
 BindingSet bindings)
                                        throws QueryEvaluationException

Throws:

QueryEvaluationException

prepare

protected QueryEvaluationStep prepare(DescribeOperator operator,
 QueryEvaluationContext context)
                               throws QueryEvaluationException

Overrides:

prepare in class DefaultEvaluationStrategy

Throws:

QueryEvaluationException

evaluateAtStatementSources

protected CloseableIteration<BindingSet> evaluateAtStatementSources(Object preparedQuery,
 List<StatementSource> statementSources,
 QueryInfo queryInfo)
                                                             throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateAtStatementSources

protected CloseableIteration<BindingSet> evaluateAtStatementSources(String preparedQuery,
 List<StatementSource> statementSources,
 QueryInfo queryInfo)
                                                             throws QueryEvaluationException

Throws:

QueryEvaluationException

evaluateAtStatementSources

protected CloseableIteration<BindingSet> evaluateAtStatementSources(TupleExpr preparedQuery,
 List<StatementSource> statementSources,
 QueryInfo queryInfo)
                                                             throws QueryEvaluationException

Throws:

QueryEvaluationException