| 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 | CheckStatementPattern. queryInfo | 
| protected QueryInfo | FedXLeftJoin. queryInfo | 
| protected QueryInfo | FedXService. queryInfo | 
| protected QueryInfo | ExclusiveGroup. queryInfo | 
| protected QueryInfo | NTuple. queryInfo | 
| protected QueryInfo | FedXStatementPattern. queryInfo | 
| Modifier and Type | Method and Description | 
|---|---|
| QueryInfo | SingleSourceQuery. getQueryInfo() | 
| QueryInfo | CheckStatementPattern. getQueryInfo() | 
| QueryInfo | ExclusiveArbitraryLengthPath. getQueryInfo() | 
| QueryInfo | FedXLeftJoin. getQueryInfo() | 
| QueryInfo | QueryRef. getQueryInfo()Retrieve the attached query information of the tuple expression | 
| QueryInfo | FedXService. getQueryInfo() | 
| QueryInfo | ExclusiveGroup. getQueryInfo() | 
| QueryInfo | NTuple. getQueryInfo() | 
| QueryInfo | FedXStatementPattern. getQueryInfo() | 
| Modifier and Type | Method and Description | 
|---|---|
| static List<StatementSource> | CacheUtils. checkCacheForStatementSourcesUpdateCache(SourceSelectionCache cache,
                                        List<Endpoint> endpoints,
                                        Resource subj,
                                        IRI pred,
                                        Value obj,
                                        QueryInfo queryInfo)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)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) | 
| 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<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) | 
| 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> | TripleSource. getStatements(Resource subj,
             IRI pred,
             Value obj,
             QueryInfo queryInfo,
             Resource... contexts)Return the statements matching the given pattern as a  Statementiteration. | 
| CloseableIteration<Statement,QueryEvaluationException> | SparqlTripleSource. getStatements(Resource subj,
             IRI pred,
             Value obj,
             QueryInfo queryInfo,
             Resource... contexts) | 
| CloseableIteration<BindingSet,QueryEvaluationException> | SailTripleSource. 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> | SparqlTripleSource. getStatements(StatementPattern stmt,
             BindingSet bindings,
             FilterValueExpr filterExpr,
             QueryInfo queryInfo) | 
| CloseableIteration<BindingSet,QueryEvaluationException> | SailTripleSource. 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> | SparqlTripleSource. getStatements(String preparedQuery,
             BindingSet bindings,
             FilterValueExpr filterExpr,
             QueryInfo queryInfo) | 
| CloseableIteration<BindingSet,QueryEvaluationException> | TripleSource. getStatements(String preparedQuery,
             QueryType queryType,
             QueryInfo queryInfo)Evaluate a given SPARQL query of the provided query type at the given source. | 
| CloseableIteration<BindingSet,QueryEvaluationException> | TripleSourceBase. getStatements(String preparedQuery,
             QueryType queryType,
             QueryInfo queryInfo) | 
| CloseableIteration<BindingSet,QueryEvaluationException> | SailTripleSource. 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. | 
| CloseableIteration<BindingSet,QueryEvaluationException> | SparqlTripleSource. getStatements(TupleExpr preparedQuery,
             BindingSet bindings,
             FilterValueExpr filterExpr,
             QueryInfo queryInfo) | 
| 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 | TripleSourceBase. hasStatements(Resource subj,
             IRI pred,
             Value obj,
             QueryInfo queryInfo,
             Resource... contexts) | 
| boolean | SparqlTripleSource. hasStatements(Resource subj,
             IRI pred,
             Value obj,
             QueryInfo queryInfo,
             Resource... contexts) | 
| boolean | SailTripleSource. hasStatements(StatementPattern stmt,
             BindingSet bindings,
             QueryInfo queryInfo) | 
| boolean | TripleSource. hasStatements(StatementPattern stmt,
             BindingSet bindings,
             QueryInfo queryInfo)Check if the provided statement can return results. | 
| boolean | SparqlTripleSource. hasStatements(StatementPattern stmt,
             BindingSet bindings,
             QueryInfo queryInfo) | 
| 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. | 
| 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 | ParallelExecutor. getQueryInfo()Return the query info of the associated query | 
| QueryInfo | ParallelExecutorBase. getQueryInfo() | 
| 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 | ParallelUnionTask. queryInfo | 
| protected QueryInfo | ParallelPreparedUnionTask. queryInfo | 
| protected QueryInfo | ParallelGetStatementsTask. queryInfo | 
| protected QueryInfo | ParallelPreparedAlgebraUnionTask. queryInfo | 
| Modifier and Type | Method and Description | 
|---|---|
| void | QueryLog. logQuery(QueryInfo query) | 
| void | MonitoringImpl. monitorQuery(QueryInfo query) | 
| void | NoopMonitoringImpl. monitorQuery(QueryInfo query) | 
| void | Monitoring. monitorQuery(QueryInfo query) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected QueryInfo | ServiceOptimizer. queryInfo | 
| protected QueryInfo | UnionOptimizer. queryInfo | 
| protected QueryInfo | StatementGroupAndJoinOptimizer. queryInfo | 
| protected QueryInfo | SourceSelection. queryInfo | 
| QueryInfo | SourceSelection.CheckTaskPair. queryInfo | 
| protected QueryInfo | SourceSelection.ParallelCheckTask. 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.