Modifier and Type | Method and Description |
---|---|
Set<QueryInfo> |
QueryManager.getRunningQueries() |
Modifier and Type | Method and Description |
---|---|
void |
QueryManager.abortQuery(QueryInfo queryInfo) |
WorkerUnionBase<BindingSet> |
FederationManager.createWorkerUnion(QueryInfo queryInfo)
Create an appropriate worker union for this federation, i.e.
|
void |
QueryManager.finishQuery(QueryInfo queryInfo) |
boolean |
QueryManager.isRunning(QueryInfo queryInfo) |
void |
QueryManager.registerQuery(QueryInfo queryInfo)
Add the query to the set of running queries, queries are identified via a unique id
|
Modifier and Type | Field and Description |
---|---|
protected QueryInfo |
FedXStatementPattern.queryInfo |
protected QueryInfo |
CheckStatementPattern.queryInfo |
protected QueryInfo |
ExclusiveGroup.queryInfo |
protected QueryInfo |
FedXLeftJoin.queryInfo |
protected QueryInfo |
NTuple.queryInfo |
protected QueryInfo |
FedXService.queryInfo |
Modifier and Type | Method and Description |
---|---|
QueryInfo |
PassThroughTupleExpr.getQueryInfo() |
QueryInfo |
ExclusiveArbitraryLengthPath.getQueryInfo() |
QueryInfo |
FedXStatementPattern.getQueryInfo() |
QueryInfo |
CheckStatementPattern.getQueryInfo() |
QueryInfo |
ExclusiveGroup.getQueryInfo() |
QueryInfo |
FedXLeftJoin.getQueryInfo() |
QueryInfo |
NTuple.getQueryInfo() |
QueryInfo |
SingleSourceQuery.getQueryInfo() |
QueryInfo |
FedXService.getQueryInfo() |
QueryInfo |
QueryRef.getQueryInfo()
Retrieve the attached query information of the tuple expression
|
Modifier and Type | Method and Description |
---|---|
static 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.
|
Modifier and Type | Method and Description |
---|---|
QueryInfo |
FederationEvaluationStatistics.getQueryInfo() |
Modifier and Type | Method and Description |
---|---|
protected void |
TripleSourceBase.configureInference(Query query,
QueryInfo queryInfo)
Set includeInferred depending on
getIncludeInferred() |
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) |
CloseableIteration<BindingSet,QueryEvaluationException> |
SparqlFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
TupleExpr rightArg,
Set<String> joinVars,
BindingSet bindings,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
SailFederationEvalStrategy.executeJoin(ControlledWorkerScheduler<BindingSet> joinScheduler,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
TupleExpr rightArg,
Set<String> joinVars,
BindingSet bindings,
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.
|
CloseableIteration<Statement,QueryEvaluationException> |
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.
|
CloseableIteration<Statement,QueryEvaluationException> |
SailTripleSource.getStatements(Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
CloseableIteration<Statement,QueryEvaluationException> |
SparqlTripleSource.getStatements(Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
CloseableIteration<Statement,QueryEvaluationException> |
TripleSource.getStatements(Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts)
Return the statements matching the given pattern as a
Statement iteration. |
CloseableIteration<BindingSet,QueryEvaluationException> |
SailTripleSource.getStatements(StatementPattern stmt,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
SparqlTripleSource.getStatements(StatementPattern stmt,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSource.getStatements(StatementPattern stmt,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo)
Evaluate the query expression on the provided endpoint.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSourceBase.getStatements(String preparedQuery,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSource.getStatements(String preparedQuery,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo)
Evaluate the prepared query (SPARQL query as String) on the provided endpoint.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSourceBase.getStatements(String preparedQuery,
BindingSet queryBindings,
QueryType queryType,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSource.getStatements(String preparedQuery,
BindingSet queryBindings,
QueryType queryType,
QueryInfo queryInfo)
Evaluate a given SPARQL query of the provided query type at the given source.
|
default CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSource.getStatements(String preparedQuery,
QueryType queryType,
QueryInfo queryInfo)
Deprecated.
|
CloseableIteration<BindingSet,QueryEvaluationException> |
SailTripleSource.getStatements(TupleExpr preparedQuery,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
SparqlTripleSource.getStatements(TupleExpr preparedQuery,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo) |
CloseableIteration<BindingSet,QueryEvaluationException> |
TripleSource.getStatements(TupleExpr preparedQuery,
BindingSet bindings,
FilterValueExpr filterExpr,
QueryInfo queryInfo)
Evaluate the prepared query in its internal representation on the provided endpoint.
|
boolean |
SparqlTripleSource.hasStatements(Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
boolean |
TripleSourceBase.hasStatements(Resource subj,
IRI pred,
Value obj,
QueryInfo queryInfo,
Resource... contexts) |
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 obj
|
boolean |
SailTripleSource.hasStatements(StatementPattern stmt,
BindingSet bindings,
QueryInfo queryInfo,
Dataset dataset) |
boolean |
SparqlTripleSource.hasStatements(StatementPattern stmt,
BindingSet bindings,
QueryInfo queryInfo,
Dataset dataset) |
boolean |
TripleSource.hasStatements(StatementPattern stmt,
BindingSet bindings,
QueryInfo queryInfo,
Dataset dataset)
Check if the provided statement can return results.
|
protected void |
FederationEvalStrategy.optimizeExclusiveExpressions(TupleExpr query,
QueryInfo queryInfo,
GenericInfoOptimizer info)
Optimize
ExclusiveTupleExpr , e.g. |
protected void |
FederationEvalStrategy.optimizeJoinOrder(TupleExpr query,
QueryInfo queryInfo,
GenericInfoOptimizer info) |
protected Set<Endpoint> |
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) |
Constructor and Description |
---|
FederationEvaluationStatistics(QueryInfo queryInfo,
Dataset dataset) |
Modifier and Type | Field and Description |
---|---|
protected QueryInfo |
ParallelExecutorBase.queryInfo |
Modifier and Type | Method and Description |
---|---|
QueryInfo |
ParallelServiceExecutor.getQueryInfo() |
QueryInfo |
ParallelExecutorBase.getQueryInfo() |
QueryInfo |
ParallelExecutor.getQueryInfo()
Return the query info of the associated query
|
default QueryInfo |
ParallelTask.getQueryInfo() |
Constructor and Description |
---|
ParallelExecutorBase(FederationEvalStrategy strategy,
QueryInfo queryInfo) |
Modifier and Type | Field and Description |
---|---|
protected QueryInfo |
StopRemainingExecutionsOnCloseIteration.queryInfo |
protected QueryInfo |
QueryResultIteration.queryInfo |
Constructor and Description |
---|
QueryResultIteration(CloseableIteration<BindingSet,QueryEvaluationException> inner,
QueryInfo queryInfo) |
StopRemainingExecutionsOnCloseIteration(CloseableIteration<? extends BindingSet,QueryEvaluationException> inner,
QueryInfo queryInfo) |
Modifier and Type | Field and Description |
---|---|
protected QueryInfo |
ParallelGetStatementsTask.queryInfo |
protected QueryInfo |
ParallelPreparedUnionTask.queryInfo |
protected QueryInfo |
ParallelPreparedAlgebraUnionTask.queryInfo |
protected QueryInfo |
ParallelUnionTask.queryInfo |
Modifier and Type | Method and Description |
---|---|
void |
QueryLog.logQuery(QueryInfo query) |
void |
NoopMonitoringImpl.monitorQuery(QueryInfo query) |
void |
MonitoringImpl.monitorQuery(QueryInfo query) |
void |
Monitoring.monitorQuery(QueryInfo query) |
Modifier and Type | Field and Description |
---|---|
protected QueryInfo |
StatementGroupAndJoinOptimizer.queryInfo |
protected QueryInfo |
SourceSelection.queryInfo |
QueryInfo |
SourceSelection.CheckTaskPair.queryInfo |
protected QueryInfo |
SourceSelection.ParallelCheckTask.queryInfo |
protected QueryInfo |
ServiceOptimizer.queryInfo |
protected QueryInfo |
UnionOptimizer.queryInfo |
protected QueryInfo |
GenericInfoOptimizer.queryInfo |
Modifier and Type | Method and Description |
---|---|
QueryInfo |
SourceSelection.SourceSelectionExecutorWithLatch.getQueryInfo() |
Modifier and Type | Method and Description |
---|---|
static NJoin |
OptimizerUtil.flattenJoin(Join join,
QueryInfo queryInfo)
Flatten the join to one layer, i.e.
|
Constructor and Description |
---|
CheckTaskPair(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) |
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.