public class ParallelUnionOperatorTask extends ParallelTaskBase<BindingSet>
| Modifier and Type | Field and Description |
|---|---|
protected BindingSet |
bindings |
protected TupleExpr |
expr |
protected FederationEvalStrategy |
strategy |
protected ParallelExecutor<BindingSet> |
unionControl |
scheduledFuture| Constructor and Description |
|---|
ParallelUnionOperatorTask(ParallelExecutor<BindingSet> unionControl,
FederationEvalStrategy strategy,
TupleExpr expr,
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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetQueryInfoprotected final ParallelExecutor<BindingSet> unionControl
protected final FederationEvalStrategy strategy
protected final TupleExpr expr
protected final BindingSet bindings
public ParallelUnionOperatorTask(ParallelExecutor<BindingSet> unionControl, FederationEvalStrategy strategy, TupleExpr expr, BindingSet bindings)
public ParallelExecutor<BindingSet> getControl()
ParallelTaskprotected CloseableIteration<BindingSet,QueryEvaluationException> performTaskInternal() throws Exception
performTaskInternal in class ParallelTaskBase<BindingSet>ExceptionCopyright © 2015-2022 Eclipse Foundation. All Rights Reserved.