public class FederatedEvaluationStrategyImpl extends EvaluationStrategyImpl
Modifier and Type | Field and Description |
---|---|
QueryExecutor |
queryExecutor |
Constructor and Description |
---|
FederatedEvaluationStrategyImpl(QueryExecutor queryExecutor) |
FederatedEvaluationStrategyImpl(QueryExecutor queryExecutor,
org.openrdf.model.ValueFactory vf) |
Modifier and Type | Method and Description |
---|---|
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactiveDefault(org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindingList) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(BindJoin expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(org.openrdf.query.algebra.Join expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(SourceQuery expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(SourceQuery expr,
List<org.openrdf.query.BindingSet> bindingList) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(Transform expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindingList) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateReactorInternal(org.openrdf.query.algebra.Union expr,
List<org.openrdf.query.BindingSet> bindingList) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateSourceReactive(org.openrdf.model.URI source,
org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings) |
reactor.rx.Stream<org.openrdf.query.BindingSet> |
evaluateSourceReactive(org.openrdf.model.URI source,
org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindings) |
int |
getBatchSize() |
void |
setBatchSize(int b) |
aggregate, evaluate, evaluate, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateReactorInternal, evaluateValue, isTrue
public QueryExecutor queryExecutor
public FederatedEvaluationStrategyImpl(QueryExecutor queryExecutor, org.openrdf.model.ValueFactory vf)
public FederatedEvaluationStrategyImpl(QueryExecutor queryExecutor)
public void setBatchSize(int b)
public int getBatchSize()
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(org.openrdf.query.algebra.TupleExpr expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
evaluateReactorInternal
in class EvaluationStrategyImpl
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(org.openrdf.query.algebra.Join expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
evaluateReactorInternal
in class EvaluationStrategyImpl
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(BindJoin expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(SourceQuery expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateSourceReactive(org.openrdf.model.URI source, org.openrdf.query.algebra.TupleExpr expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateSourceReactive(org.openrdf.model.URI source, org.openrdf.query.algebra.TupleExpr expr, List<org.openrdf.query.BindingSet> bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(Transform expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(org.openrdf.query.algebra.TupleExpr expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(SourceQuery expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactiveDefault(org.openrdf.query.algebra.TupleExpr expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public reactor.rx.Stream<org.openrdf.query.BindingSet> evaluateReactorInternal(org.openrdf.query.algebra.Union expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
Copyright © 2015 SemaGrow - FP7. All rights reserved.