Class SailTripleSource

java.lang.Object

org.eclipse.rdf4j.federated.evaluation.TripleSourceBase

org.eclipse.rdf4j.federated.evaluation.SailTripleSource

All Implemented Interfaces:

TripleSource

public class SailTripleSource
extends TripleSourceBase

A triple source to be used on any repository.

Author:

Andreas Schwarte

Nested Class Summary

Nested classes/interfaces inherited from class TripleSourceBase

TripleSourceBase.ConnectionOperation<T>, TripleSourceBase.ResultHolder<T>

Modifier and Type	Class	Description
protected static interface	TripleSourceBase.ConnectionOperation<T>	Interface defining the operation to be perform on the connection
protected static class	TripleSourceBase.ResultHolder<T>	Holder for a result iteration to be used with TripleSourceBase.withConnection(ConnectionOperation).

Field Summary

Fields inherited from class TripleSourceBase

endpoint, federationContext, monitoringService

Modifier and Type	Field	Description
protected final Endpoint	endpoint
protected final FederationContext	federationContext
protected final Monitoring	monitoringService

Method Summary

Modifier and Type	Method	Description
CloseableIteration<Statement>	getStatements(Resource subj, IRI pred, Value obj, QueryInfo queryInfo, Resource... contexts)	Return the statements matching the given pattern as a Statement iteration.
CloseableIteration<BindingSet>	getStatements(StatementPattern stmt, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)	Evaluate the query expression on the provided endpoint.
CloseableIteration<BindingSet>	getStatements(TupleExpr preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)	Evaluate the prepared query in its internal representation on the provided endpoint.
boolean	hasStatements(StatementPattern stmt, BindingSet bindings, QueryInfo queryInfo, Dataset dataset)	Check if the provided statement can return results.
boolean	usePreparedQuery(StatementPattern stmt, QueryInfo queryInfo)

Methods inherited from class TripleSourceBase

applyMaxExecutionTimeUpperBound, configureInference, getStatements, getStatements, hasStatements, hasStatements, monitorRemoteRequest, withConnection

Modifier and Type	Method	Description
protected void	applyMaxExecutionTimeUpperBound(Operation operation)	Apply an upper bound of the maximum execution time using FedXUtil.applyMaxQueryExecutionTime(Operation, FederationContext).
protected void	configureInference(Query query, QueryInfo queryInfo)	Set includeInferred depending on QueryInfo.getIncludeInferred()
CloseableIteration<BindingSet>	getStatements(String preparedQuery, BindingSet bindings, FilterValueExpr filterExpr, QueryInfo queryInfo)	Evaluate the prepared query (SPARQL query as String) on the provided endpoint.
CloseableIteration<BindingSet>	getStatements(String preparedQuery, BindingSet queryBindings, QueryType queryType, QueryInfo queryInfo)	Evaluate a given SPARQL query of the provided query type at the given source.
boolean	hasStatements(ExclusiveTupleExpr group, BindingSet bindings)	Check if the repository can return results for the given ExclusiveTupleExpr, e.g. for an ExclusiveGroup with a list of Statements.
boolean	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
protected void	monitorRemoteRequest()
protected <T> CloseableIteration<T>	withConnection(TripleSourceBase.ConnectionOperation<T> operation)	Convenience method to perform an operation on a RepositoryConnection.

Methods inherited from class Object

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

Method Details

getStatements

public CloseableIteration<BindingSet> getStatements(StatementPattern stmt,
 BindingSet bindings,
 FilterValueExpr filterExpr,
 QueryInfo queryInfo)
                                             throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Description copied from interface: TripleSource

Evaluate the query expression on the provided endpoint.

Parameters:

stmt - the stmt expression to evaluate

bindings - the bindings to use

filterExpr - the filter expression to apply or null if there is no filter or if it is evaluated already

Returns:

the resulting iteration

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

getStatements

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

Description copied from interface: TripleSource

Return the statements matching the given pattern as a Statement iteration.

Parameters:

subj -

pred -

obj -

contexts -

Returns:

the resulting iteration

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

hasStatements

public boolean hasStatements(StatementPattern stmt,
 BindingSet bindings,
 QueryInfo queryInfo,
 Dataset dataset)
                      throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Description copied from interface: TripleSource

Check if the provided statement can return results.

Parameters:

stmt -

bindings - a binding set. in case no bindings are present, an EmptyBindingSet can be used (i.e. never null)

queryInfo -

dataset -

Returns:

whether the source can return results

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

usePreparedQuery

public boolean usePreparedQuery(StatementPattern stmt,
 QueryInfo queryInfo)

Parameters:

stmt -

queryInfo -

Returns:

true if a prepared query is to be used preferably, false otherwise

getStatements

public CloseableIteration<BindingSet> getStatements(TupleExpr preparedQuery,
 BindingSet bindings,
 FilterValueExpr filterExpr,
 QueryInfo queryInfo)
                                             throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Description copied from interface: TripleSource

Evaluate the prepared query in its internal representation on the provided endpoint.

Parameters:

preparedQuery - a prepared query to evaluate

bindings - the bindings to use

filterExpr - the filter expression to apply or null if there is no filter or if it is evaluated already

Returns:

the resulting iteration

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException