Uses of Class
org.eclipse.rdf4j.federated.structures.QueryInfo
Package
Description
-
Uses of QueryInfo in org.eclipse.rdf4j.federated
Modifier and TypeMethodDescriptionvoid
QueryManager.abortQuery(QueryInfo queryInfo)
FederationManager.createWorkerUnion(QueryInfo queryInfo)
Create an appropriate worker union for this federation, i.e.void
QueryManager.finishQuery(QueryInfo queryInfo)
boolean
void
QueryManager.registerQuery(QueryInfo queryInfo)
Add the query to the set of running queries, queries are identified via a unique id -
Uses of QueryInfo in org.eclipse.rdf4j.federated.algebra
Modifier and TypeFieldDescriptionprotected QueryInfo
CheckStatementPattern.queryInfo
protected QueryInfo
ExclusiveGroup.queryInfo
protected QueryInfo
FedXLeftJoin.queryInfo
protected QueryInfo
FedXService.queryInfo
protected QueryInfo
FedXStatementPattern.queryInfo
protected QueryInfo
NTuple.queryInfo
Modifier and TypeMethodDescriptionCheckStatementPattern.getQueryInfo()
ExclusiveArbitraryLengthPath.getQueryInfo()
ExclusiveGroup.getQueryInfo()
FederatedDescribeOperator.getQueryInfo()
FedXLeftJoin.getQueryInfo()
FedXService.getQueryInfo()
FedXStatementPattern.getQueryInfo()
NTuple.getQueryInfo()
PassThroughTupleExpr.getQueryInfo()
QueryRef.getQueryInfo()
Retrieve the attached query information of the tuple expressionSingleSourceQuery.getQueryInfo()
ModifierConstructorDescriptionCheckStatementPattern(StatementTupleExpr stmt, QueryInfo queryInfo)
EmptyNJoin(NJoin njoin, QueryInfo queryInfo)
EmptyNUnion(List<TupleExpr> args, QueryInfo queryInfo)
ExclusiveArbitraryLengthPath(ArbitraryLengthPath path, StatementSource owner, QueryInfo queryInfo)
ExclusiveGroup(Collection<? extends ExclusiveTupleExpr> ownedNodes, StatementSource owner, QueryInfo queryInfo)
ExclusiveStatement(StatementPattern node, StatementSource owner, QueryInfo queryInfo)
FederatedDescribeOperator(TupleExpr arg, QueryInfo queryInfo)
FedXLeftJoin(LeftJoin leftJoin, QueryInfo queryInfo)
FedXService(Service expr, QueryInfo queryInfo)
FedXStatementPattern(StatementPattern node, QueryInfo queryInfo)
Construct an nary-tuple.Construct an nary-tuple.Construct an nary-tuple.SingleSourceQuery(TupleExpr parsedQuery, Endpoint source, QueryInfo queryInfo)
StatementSourcePattern(StatementPattern node, QueryInfo queryInfo)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.cache
Modifier and TypeMethodDescriptionstatic List<StatementSource>
CacheUtils.checkCacheForStatementSourcesUpdateCache(SourceSelectionCache cache, List<Endpoint> endpoints, Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
Checks the cache for relevant statement sources to the provided statement.static boolean
CacheUtils.checkCacheUpdateCache(SourceSelectionCache cache, List<Endpoint> endpoints, Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
Checks the cache if some endpoint can provide results to the subquery. -
Uses of QueryInfo in org.eclipse.rdf4j.federated.evaluation
Modifier and TypeMethodDescriptionprotected void
TripleSourceBase.configureInference(Query query, QueryInfo queryInfo)
Set includeInferred depending ongetIncludeInferred()
protected CloseableIteration<BindingSet,QueryEvaluationException>
FederationEvalStrategy.evaluateAtStatementSources(Object preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
protected CloseableIteration<BindingSet,QueryEvaluationException>
FederationEvalStrategy.evaluateAtStatementSources(String preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
protected CloseableIteration<BindingSet,QueryEvaluationException>
FederationEvalStrategy.evaluateAtStatementSources(TupleExpr preparedQuery, List<StatementSource> statementSources, QueryInfo queryInfo)
protected abstract CloseableIteration<BindingSet,QueryEvaluationException>
FederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, Set<String> joinVariables, BindingSet bindings, QueryInfo queryInfo)
Execute the join in a separate thread using some join executor.SailFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo)
SparqlFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo)
FederationEvalStrategy.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.SailTripleSource.getStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
SailTripleSource.getStatements(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
SailTripleSource.getStatements(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
SparqlTripleSource.getStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
SparqlTripleSource.getStatements(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
SparqlTripleSource.getStatements(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
TripleSource.getStatements(String preparedQuery, QueryType queryType, QueryInfo queryInfo)
Deprecated.TripleSource.getStatements(String preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
Evaluate the prepared query (SPARQL query as String) on the provided endpoint.TripleSource.getStatements(String preparedQuery, BindingSet queryBindings, QueryType queryType, QueryInfo queryInfo)
Evaluate a given SPARQL query of the provided query type at the given source.TripleSource.getStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
Return the statements matching the given pattern as aStatement
iteration.TripleSource.getStatements(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
Evaluate the query expression on the provided endpoint.TripleSource.getStatements(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
Evaluate the prepared query in its internal representation on the provided endpoint.TripleSourceBase.getStatements(String preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
TripleSourceBase.getStatements(String preparedQuery, BindingSet queryBindings, QueryType queryType, QueryInfo queryInfo)
boolean
SailTripleSource.hasStatements(StatementPattern stmt, BindingSet bindings, QueryInfo queryInfo, Dataset dataset)
boolean
SparqlTripleSource.hasStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
boolean
SparqlTripleSource.hasStatements(StatementPattern stmt, BindingSet bindings, QueryInfo queryInfo, Dataset dataset)
boolean
TripleSource.hasStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
Check if the repository can return results for the given triple pattern represented by subj, pred and objboolean
TripleSource.hasStatements(StatementPattern stmt, BindingSet bindings, QueryInfo queryInfo, Dataset dataset)
Check if the provided statement can return results.boolean
TripleSourceBase.hasStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
protected void
FederationEvalStrategy.optimizeExclusiveExpressions(TupleExpr query, QueryInfo queryInfo, GenericInfoOptimizer info)
OptimizeExclusiveTupleExpr
, e.g.protected void
FederationEvalStrategy.optimizeJoinOrder(TupleExpr query, QueryInfo queryInfo, GenericInfoOptimizer info)
FederationEvalStrategy.performSourceSelection(List<Endpoint> members, SourceSelectionCache cache, QueryInfo queryInfo, GenericInfoOptimizer info)
Perform source selection for all statements of the query.boolean
SailTripleSource.usePreparedQuery(StatementPattern stmt, QueryInfo queryInfo)
boolean
SparqlTripleSource.usePreparedQuery(StatementPattern stmt, QueryInfo queryInfo)
boolean
TripleSource.usePreparedQuery(StatementPattern stmt, QueryInfo queryInfo)
ModifierConstructorDescriptionFederationEvaluationStatistics(QueryInfo queryInfo, Dataset dataset)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.evaluation.concurrent
Modifier and TypeMethodDescriptionParallelExecutor.getQueryInfo()
Return the query info of the associated queryParallelExecutorBase.getQueryInfo()
ParallelServiceExecutor.getQueryInfo()
default QueryInfo
ParallelTask.getQueryInfo()
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.evaluation.iterator
Modifier and TypeFieldDescriptionprotected QueryInfo
QueryResultIteration.queryInfo
protected QueryInfo
StopRemainingExecutionsOnCloseIteration.queryInfo
ModifierConstructorDescriptionFederatedDescribeIteration(Iteration<BindingSet,QueryEvaluationException> sourceIter, FederationEvalStrategy strategy, Set<String> describeExprNames, BindingSet parentBindings, QueryInfo queryInfo)
QueryResultIteration(CloseableIteration<BindingSet,QueryEvaluationException> inner, QueryInfo queryInfo)
StopRemainingExecutionsOnCloseIteration(CloseableIteration<? extends BindingSet,QueryEvaluationException> inner, QueryInfo queryInfo)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.evaluation.join
ModifierConstructorDescriptionControlledWorkerBoundJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
ControlledWorkerJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
ControlledWorkerLeftJoin(ControlledWorkerScheduler<BindingSet> scheduler, FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, LeftJoin join, BindingSet bindings, QueryInfo queryInfo)
HashJoin(FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, QueryEvaluationStep rightPrepared, Set<String> joinVars, BindingSet bindings, QueryInfo queryInfo)
JoinExecutorBase(FederationEvalStrategy strategy, CloseableIteration<T,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
SynchronousBoundJoin(FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
SynchronousJoin(FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.evaluation.union
Modifier and TypeFieldDescriptionprotected QueryInfo
ParallelGetStatementsTask.queryInfo
protected QueryInfo
ParallelPreparedAlgebraUnionTask.queryInfo
protected QueryInfo
ParallelPreparedUnionTask.queryInfo
protected QueryInfo
ParallelUnionTask.queryInfo
ModifierConstructorDescriptionControlledWorkerUnion(ControlledWorkerScheduler<T> scheduler, QueryInfo queryInfo)
ParallelGetStatementsTask(ParallelExecutor<Statement> unionControl, Endpoint endpoint, Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)
ParallelPreparedAlgebraUnionTask(ParallelExecutor<BindingSet> unionControl, TupleExpr preparedQuery, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
ParallelPreparedUnionTask(ParallelExecutor<BindingSet> unionControl, String preparedQuery, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
ParallelUnionTask(ParallelExecutor<BindingSet> unionControl, StatementPattern stmt, Endpoint endpoint, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)
SynchronousWorkerUnion(QueryInfo queryInfo)
UnionExecutorBase(QueryInfo queryInfo)
WorkerUnionBase(QueryInfo queryInfo)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.monitoring
Modifier and TypeMethodDescriptionvoid
void
Monitoring.monitorQuery(QueryInfo query)
void
MonitoringImpl.monitorQuery(QueryInfo query)
void
NoopMonitoringImpl.monitorQuery(QueryInfo query)
-
Uses of QueryInfo in org.eclipse.rdf4j.federated.optimizer
Modifier and TypeFieldDescriptionprotected QueryInfo
GenericInfoOptimizer.queryInfo
protected QueryInfo
ServiceOptimizer.queryInfo
SourceSelection.CheckTaskPair.queryInfo
protected QueryInfo
SourceSelection.ParallelCheckTask.queryInfo
protected QueryInfo
SourceSelection.queryInfo
protected QueryInfo
StatementGroupAndJoinOptimizer.queryInfo
protected QueryInfo
UnionOptimizer.queryInfo
Modifier and TypeMethodDescriptionSourceSelection.SourceSelectionExecutorWithLatch.getQueryInfo()
Modifier and TypeMethodDescriptionstatic NJoin
OptimizerUtil.flattenJoin(Join join, QueryInfo queryInfo)
Flatten the join to one layer, i.e.ModifierConstructorDescriptionCheckTaskPair(Endpoint e, StatementPattern t, QueryInfo queryInfo)
GenericInfoOptimizer(QueryInfo queryInfo)
ParallelCheckTask(Endpoint endpoint, StatementPattern stmt, QueryInfo queryInfo, SourceSelection.SourceSelectionExecutorWithLatch control)
ServiceOptimizer(QueryInfo queryInfo)
SourceSelection(List<Endpoint> endpoints, SourceSelectionCache cache, QueryInfo queryInfo)
StatementGroupAndJoinOptimizer(QueryInfo queryInfo, FedXCostModel costModel)
UnionOptimizer(QueryInfo queryInfo)