Class SPARQLFederatedService

java.lang.Object

org.eclipse.rdf4j.repository.sparql.federation.RepositoryFederatedService

org.eclipse.rdf4j.repository.sparql.federation.SPARQLFederatedService

All Implemented Interfaces:

FederatedService

public class SPARQLFederatedService
extends RepositoryFederatedService

Federated Service wrapping the SPARQLRepository to communicate with a SPARQL endpoint.

Author:

Andreas Schwarte

Field Summary

Fields inherited from class RepositoryFederatedService

boundJoinBlockSize, shutDown

Modifier and Type	Field	Description
protected int	boundJoinBlockSize	The number of bindings sent in a single subquery in RepositoryFederatedService.evaluate(Service, CloseableIteration, String) If blockSize is set to 0, the entire input stream is used as block input the block size effectively determines the number of remote requests
protected boolean	shutDown

Constructor Summary

Constructors

Constructor	Description
SPARQLFederatedService(String serviceUrl, HttpClientSessionManager client)

Method Summary

Methods inherited from class RepositoryFederatedService

ask, evaluate, evaluateInternal, getBoundJoinBlockSize, getConnection, initialize, insertValuesClause, isInitialized, select, setBoundJoinBlockSize, setUseFreshConnection, shutdown, wrap

Modifier and Type	Method	Description
boolean	ask(Service service, BindingSet bindings, String baseUri)	Evaluate the provided sparqlQueryString at the initialized Repository of this FederatedService.
CloseableIteration<BindingSet>	evaluate(Service service, CloseableIteration<BindingSet> bindings, String baseUri)	Evaluate the provided SPARQL query at this federated service, possibilities for vectored evaluation.
protected CloseableIteration<BindingSet>	evaluateInternal(Service service, CloseableIteration<BindingSet> bindings, String baseUri)	Evaluate the SPARQL query that can be constructed from the SERVICE node at the initialized Repository of this FederatedService.
int	getBoundJoinBlockSize()
protected RepositoryConnection	getConnection()	Retrieve a (re-usable) connection.
void	initialize()	Method to perform any initializations, invoked after construction.
protected String	insertValuesClause(String queryString, String valuesClause)	Insert the constructed VALUES clause in the beginning of the WHERE block.
boolean	isInitialized()	Method to check if FederatedService.initialize() had been called.
CloseableIteration<BindingSet>	select(Service service, Set<String> projectionVars, BindingSet bindings, String baseUri)	Evaluate the provided sparqlQueryString at the initialized Repository of this FederatedService.
void	setBoundJoinBlockSize(int boundJoinBlockSize)
void	setUseFreshConnection(boolean flag)
void	shutdown()	Method to perform any shutDown code, invoked at unregistering.
protected Runnable	wrap(Runnable runnable)	Callback to wrap the runnable prior to passing it to the background Executor.

Methods inherited from class Object

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

Constructor Details

SPARQLFederatedService

public SPARQLFederatedService(String serviceUrl,
 HttpClientSessionManager client)

Parameters:

serviceUrl - the serviceUrl use to initialize the inner SPARQLRepository