public class ParallelBoundJoinTask extends ParallelTaskBase<BindingSet>
FederationEvalStrategy.evaluateBoundJoinStatementPattern(StatementTupleExpr, List)
for further details on the
evaluation process.Modifier and Type | Field and Description |
---|---|
protected List<BindingSet> |
bindings |
protected StatementTupleExpr |
expr |
protected ParallelExecutor<BindingSet> |
joinControl |
protected FederationEvalStrategy |
strategy |
scheduledFuture
Constructor and Description |
---|
ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl,
FederationEvalStrategy strategy,
StatementTupleExpr expr,
List<BindingSet> bindings) |
Modifier and Type | Method and Description |
---|---|
ParallelExecutor<BindingSet> |
getControl()
return the controlling instance, e.g.
|
protected CloseableIteration<BindingSet,QueryEvaluationException> |
performTaskInternal() |
cancel, performTask, setScheduledFuture, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getQueryInfo
protected final FederationEvalStrategy strategy
protected final StatementTupleExpr expr
protected final List<BindingSet> bindings
protected final ParallelExecutor<BindingSet> joinControl
public ParallelBoundJoinTask(ParallelExecutor<BindingSet> joinControl, FederationEvalStrategy strategy, StatementTupleExpr expr, List<BindingSet> bindings)
protected CloseableIteration<BindingSet,QueryEvaluationException> performTaskInternal() throws Exception
performTaskInternal
in class ParallelTaskBase<BindingSet>
Exception
public ParallelExecutor<BindingSet> getControl()
ParallelTask
Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.