public class SailFederationEvalStrategy extends FederationEvalStrategy
ControlledWorkerJoincache, executor, federationContextdataset, serviceResolver, tripleSource| Constructor and Description |
|---|
SailFederationEvalStrategy(FederationContext federationContext) |
| Modifier and Type | Method and Description |
|---|---|
CloseableIteration<BindingSet,QueryEvaluationException> |
evaluateBoundJoinStatementPattern(StatementTupleExpr stmt,
List<BindingSet> bindings)
Evaluate a bound join at the relevant endpoint, i.e.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
evaluateExclusiveGroup(ExclusiveGroup group,
BindingSet bindings) |
CloseableIteration<BindingSet,QueryEvaluationException> |
evaluateGroupedCheck(CheckStatementPattern stmt,
List<BindingSet> bindings)
Perform a grouped check at the relevant endpoints, i.e.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
TupleExpr rightArg,
Set<String> joinVars,
BindingSet bindings,
QueryInfo queryInfo)
Execute the join in a separate thread using some join executor.
|
createSourceSelectionCache, evaluate, evaluate, evaluate, evaluate, evaluateAtStatementSources, evaluateAtStatementSources, evaluateAtStatementSources, evaluateExclusiveTupleExpr, evaluateLeftJoin, evaluateNaryUnion, evaluateNJoin, evaluateService, evaluateService, evaluateSingleSourceQuery, getStatements, optimize, optimizeExclusiveExpressions, optimizeJoinOrder, performSourceSelection, propagateServicesevaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, evaluate, getLimit, getService, getUUID, getVarValue, getZeroLengthPathIterator, isReducedOrDistinct, isTrue, isUnbound, setFederatedServiceResolver, setOptimizerPipeline, setTrackResultSize, setTrackTimepublic SailFederationEvalStrategy(FederationContext federationContext)
public CloseableIteration<BindingSet,QueryEvaluationException> evaluateBoundJoinStatementPattern(StatementTupleExpr stmt, List<BindingSet> bindings) throws QueryEvaluationException
FederationEvalStrategyevaluateBoundJoinStatementPattern in class FederationEvalStrategyQueryEvaluationExceptionpublic CloseableIteration<BindingSet,QueryEvaluationException> evaluateGroupedCheck(CheckStatementPattern stmt, List<BindingSet> bindings) throws QueryEvaluationException
FederationEvalStrategyevaluateGroupedCheck in class FederationEvalStrategyQueryEvaluationExceptionpublic CloseableIteration<BindingSet,QueryEvaluationException> executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo) throws QueryEvaluationException
FederationEvalStrategySynchronousJoin - SynchronousBoundJoin -
ControlledWorkerJoin - ControlledWorkerBoundJoin
For endpoint federation use controlled worker bound join, for local federation use controlled worker join. The
other operators are there for completeness.
Use FederationEvalStrategy.executor to execute the join (it is a runnable).executeJoin in class FederationEvalStrategyQueryEvaluationExceptionpublic CloseableIteration<BindingSet,QueryEvaluationException> evaluateExclusiveGroup(ExclusiveGroup group, BindingSet bindings) throws RepositoryException, MalformedQueryException, QueryEvaluationException
evaluateExclusiveGroup in class FederationEvalStrategyRepositoryExceptionMalformedQueryExceptionQueryEvaluationExceptionCopyright © 2015-2022 Eclipse Foundation. All Rights Reserved.