public class RepositoryFederatedService extends Object implements FederatedService
Repository to communicate with a SPARQL endpoint.| Modifier and Type | Field and Description |
|---|---|
protected RepositoryConnection |
conn |
protected Repository |
rep |
protected boolean |
shutDown |
| Constructor and Description |
|---|
RepositoryFederatedService(Repository repo) |
RepositoryFederatedService(Repository repo,
boolean shutDown) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ask(Service service,
BindingSet bindings,
String baseUri)
Evaluate the provided sparqlQueryString at the initialized
Repository of this FederatedService. |
CloseableIteration<BindingSet,QueryEvaluationException> |
evaluate(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri)
Evaluate the provided SPARQL query at this federated service, possibilities for vectored evaluation.
|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
evaluateInternal(Service service,
CloseableIteration<BindingSet,QueryEvaluationException> bindings,
String baseUri)
Evaluate the SPARQL query that can be constructed from the SERVICE node at the initialized
Repository of
this FederatedService. |
protected RepositoryConnection |
getConnection() |
void |
initialize()
Method to perform any initializations, invoked after construction.
|
boolean |
isInitialized()
Method to check if
FederatedService.initialize() had been called. |
CloseableIteration<BindingSet,QueryEvaluationException> |
select(Service service,
Set<String> projectionVars,
BindingSet bindings,
String baseUri)
Evaluate the provided sparqlQueryString at the initialized
Repository of this FederatedService. |
void |
shutdown()
Method to perform any shutDown code, invoked at unregistering.
|
protected final Repository rep
protected boolean shutDown
protected RepositoryConnection conn
public RepositoryFederatedService(Repository repo)
repo - the repository to be usedpublic RepositoryFederatedService(Repository repo, boolean shutDown)
repo - the repository to be usedshutDown - a flag indicating whether the repository shall be closed in shutdown()public CloseableIteration<BindingSet,QueryEvaluationException> select(Service service, Set<String> projectionVars, BindingSet bindings, String baseUri) throws QueryEvaluationException
Repository of this FederatedService.
Insert bindings into SELECT query and evaluateselect in interface FederatedServiceservice - the reference to the service node, contains additional meta information (vars, prefixes)projectionVars - The variables with unknown value that should be projected from this evaluationbindings - the bindings serving as additional constraintsQueryEvaluationException - If there was an exception generated while evaluating the query.public boolean ask(Service service, BindingSet bindings, String baseUri) throws QueryEvaluationException
Repository of this FederatedService.
Insert bindings, send ask query and return final resultask in interface FederatedServiceservice - the reference to the service node, contains additional meta information (vars, prefixes)bindings - the bindings serving as additional constraintstrue if at least one result existsQueryEvaluationException - If there was an exception generated while evaluating the query.public CloseableIteration<BindingSet,QueryEvaluationException> evaluate(Service service, CloseableIteration<BindingSet,QueryEvaluationException> bindings, String baseUri) throws QueryEvaluationException
FederatedServiceContracts:
Compare SPARQLFederatedService for a reference implementation
evaluate in interface FederatedServiceservice - the reference to the service node, contains information to construct the querybindings - the bindings serving as additional constraints (for vectored evaluation)baseUri - the baseUriQueryEvaluationException - If there was an exception generated while evaluating the query.protected CloseableIteration<BindingSet,QueryEvaluationException> evaluateInternal(Service service, CloseableIteration<BindingSet,QueryEvaluationException> bindings, String baseUri) throws QueryEvaluationException
Repository of
this FederatedService. Use specified bindings as constraints to the query. Try to evaluate using BINDINGS
clause, if this yields an exception fall back to the naive implementation. This method deals with SILENT
SERVICEs.QueryEvaluationExceptionpublic void initialize()
throws QueryEvaluationException
FederatedServiceinitialize in interface FederatedServiceQueryEvaluationException - If there was an exception generated while initializing the service.public boolean isInitialized()
FederatedServiceFederatedService.initialize() had been called.isInitialized in interface FederatedServicepublic void shutdown()
throws QueryEvaluationException
FederatedServiceshutdown in interface FederatedServiceQueryEvaluationException - If there was an exception generated while shutting down the service.protected RepositoryConnection getConnection() throws RepositoryException
RepositoryExceptionCopyright © 2015-2020 Eclipse Foundation. All Rights Reserved.