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 |
---|---|
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveDefault(org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindingList) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(BindJoin expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(HashJoin expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(org.openrdf.query.algebra.Join expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(SourceQuery expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(SourceQuery expr,
List<org.openrdf.query.BindingSet> bindingList) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(Transform expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindingList) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateReactiveInternal(org.openrdf.query.algebra.Union expr,
List<org.openrdf.query.BindingSet> bindingList) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateSourceReactive(org.openrdf.model.URI source,
org.openrdf.query.algebra.TupleExpr expr,
org.openrdf.query.BindingSet bindings) |
rx.Observable<org.openrdf.query.BindingSet> |
evaluateSourceReactive(org.openrdf.model.URI source,
org.openrdf.query.algebra.TupleExpr expr,
List<org.openrdf.query.BindingSet> bindings) |
int |
getBatchSize() |
static rx.Observable<org.openrdf.query.BindingSet> |
hashJoin(rx.Observable<org.openrdf.query.BindingSet> left,
rx.Observable<org.openrdf.query.BindingSet> right,
Set<String> joinAttributes) |
void |
setBatchSize(int b) |
evaluate, evaluate, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, evaluateReactiveInternal, 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 rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(org.openrdf.query.algebra.TupleExpr expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
evaluateReactiveInternal
in class EvaluationStrategyImpl
org.openrdf.query.QueryEvaluationException
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(org.openrdf.query.algebra.Join expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
evaluateReactiveInternal
in class EvaluationStrategyImpl
org.openrdf.query.QueryEvaluationException
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(HashJoin expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public static rx.Observable<org.openrdf.query.BindingSet> hashJoin(rx.Observable<org.openrdf.query.BindingSet> left, rx.Observable<org.openrdf.query.BindingSet> right, Set<String> joinAttributes)
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(BindJoin expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(SourceQuery expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public rx.Observable<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 rx.Observable<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 rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(Transform expr, org.openrdf.query.BindingSet bindings) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(org.openrdf.query.algebra.TupleExpr expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(SourceQuery expr, List<org.openrdf.query.BindingSet> bindingList) throws org.openrdf.query.QueryEvaluationException
org.openrdf.query.QueryEvaluationException
public rx.Observable<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 rx.Observable<org.openrdf.query.BindingSet> evaluateReactiveInternal(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.