Package org.eclipse.rdf4j.federated.evaluation

Class TripleSourceBase

java.lang.Object

org.eclipse.rdf4j.federated.evaluation.TripleSourceBase

All Implemented Interfaces:

TripleSource

Direct Known Subclasses:

SailTripleSource, SparqlTripleSource

public abstract class TripleSourceBase
extends Object
implements TripleSource

Nested Class Summary

Nested Classes

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 withConnection(ConnectionOperation).

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TripleSourceBase(FederationContext federationContext, Endpoint endpoint)

Method Summary

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.
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 java.lang.Object

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

Methods inherited from interface org.eclipse.rdf4j.federated.evaluation.TripleSource

getStatements, getStatements, getStatements, hasStatements, usePreparedQuery

Field Details

federationContext

protected final FederationContext federationContext

monitoringService

protected final Monitoring monitoringService

endpoint

protected final Endpoint endpoint

Constructor Details

TripleSourceBase

public TripleSourceBase(FederationContext federationContext,
 Endpoint endpoint)

Method Details

getStatements

public CloseableIteration<BindingSet> getStatements(String preparedQuery,
 BindingSet queryBindings,
 QueryType queryType,
 QueryInfo queryInfo)
                                             throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Description copied from interface: TripleSource

Evaluate a given SPARQL query of the provided query type at the given source.

Specified by:

getStatements in interface TripleSource

Parameters:

preparedQuery -

queryBindings - optional query bindings, use EmptyBindingSet if there are none

queryType -

queryInfo -

Returns:

the statements

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

getStatements

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

Description copied from interface: TripleSource

Evaluate the prepared query (SPARQL query as String) on the provided endpoint.

Specified by:

getStatements in interface TripleSource

Parameters:

preparedQuery - a prepared query to evaluate (SPARQL query as String)

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

hasStatements

public boolean hasStatements(Resource subj,
 IRI pred,
 Value obj,
 QueryInfo queryInfo,
 Resource... contexts)
                      throws RepositoryException

Description copied from interface: TripleSource

Check if the repository can return results for the given triple pattern represented by subj, pred and obj

Specified by:

hasStatements in interface TripleSource

Parameters:

subj -

pred -

obj -

queryInfo -

contexts -

Returns:

whether the source can provide results

Throws:

RepositoryException

hasStatements

public boolean hasStatements(ExclusiveTupleExpr group,
 BindingSet bindings)
                      throws RepositoryException,
MalformedQueryException,
QueryEvaluationException

Description copied from interface: TripleSource

Check if the repository can return results for the given ExclusiveTupleExpr, e.g. for an ExclusiveGroup with a list of Statements.

Specified by:

hasStatements in interface TripleSource

Parameters:

bindings -

Returns:

whether the repository can return results

Throws:

RepositoryException

MalformedQueryException

QueryEvaluationException

monitorRemoteRequest

protected void monitorRemoteRequest()

configureInference

protected void configureInference(Query query,
 QueryInfo queryInfo)

Set includeInferred depending on QueryInfo.getIncludeInferred()

Parameters:

query -

queryInfo -

applyMaxExecutionTimeUpperBound

protected void applyMaxExecutionTimeUpperBound(Operation operation)

Apply an upper bound of the maximum execution time using FedXUtil.applyMaxQueryExecutionTime(Operation, FederationContext).

Parameters:

operation - the operation

withConnection

protected <T> CloseableIteration<T> withConnection(TripleSourceBase.ConnectionOperation<T> operation)

Convenience method to perform an operation on a RepositoryConnection. This method takes care for closing resources as well error handling. The resulting iteration has to be supplied to the TripleSourceBase.ResultHolder.

Parameters:

operation - the TripleSourceBase.ConnectionOperation

Returns:

the resulting iteration