public class QueryExecutorImpl extends ConnectionManager implements QueryExecutor
Implementation of QueryExecutor interface. The implementation uses Reactor Streams library.
Constructor and Description |
---|
QueryExecutorImpl(QueryLogHandler qfrHandler,
MaterializationManager mat) |
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<org.openrdf.query.BindingSet> |
evaluate(org.openrdf.model.URI endpoint,
org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings)
Evaluation of a remote query to a specified endpoint, given a binding.
|
org.reactivestreams.Publisher<org.openrdf.query.BindingSet> |
evaluate(org.openrdf.model.URI endpoint,
org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindingList)
Evaluation of a remote query to a specified endpoint, given a list of bindings.
|
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorImpl(org.openrdf.model.URI endpoint,
org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings)
Evaluation of a remote query to a specified endpoint, given a binding
|
closeQuietly, getConnection, initialize, shutdown
public QueryExecutorImpl(QueryLogHandler qfrHandler, MaterializationManager mat)
public org.reactivestreams.Publisher<org.openrdf.query.BindingSet> evaluate(org.openrdf.model.URI endpoint, org.openrdf.query.algebra.TupleExpr expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
evaluate
in interface QueryExecutor
endpoint
- The endpoint in which the source query is to be sentexpr
- The tuple expression that corresponds to the source querybindings
- a list of bindingsorg.openrdf.query.QueryEvaluationException
public org.reactivestreams.Publisher<org.openrdf.query.BindingSet> evaluate(org.openrdf.model.URI endpoint, org.openrdf.query.algebra.TupleExpr expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
evaluate
in interface QueryExecutor
endpoint
- The endpoint in which the source query is to be sentexpr
- The tuple expression that corresponds to the source querybindingList
- a list of bindingsorg.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorImpl(org.openrdf.model.URI endpoint, org.openrdf.query.algebra.TupleExpr expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
endpoint
- The endpoint in which the source query is to be sentexpr
- The tuple expression that corresponds to the source querybindings
- the bindingorg.openrdf.query.QueryEvaluationException
Copyright © 2015 SemaGrow - FP7. All rights reserved.