public abstract class UnionExecutorBase<T> extends ParallelExecutorBase<T>
LookAheadIteration and thus any implementation of this class is applicable for
pipelining when used in a different thread (access to shared variables is synchronized).closed, evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy| Constructor and Description |
|---|
UnionExecutorBase(FederationEvalStrategy strategy,
QueryInfo queryInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
getExecutorType() |
protected void |
performExecution()
Perform the parallel execution.
|
protected abstract void |
union()
Note: this method must block until the union is executed completely.
|
addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, handleClose, isFinished, run, toss, toStringhasNext, next, removeclose, isClosedpublic UnionExecutorBase(FederationEvalStrategy strategy, QueryInfo queryInfo)
protected final void performExecution()
throws Exception
ParallelExecutorBaseperformExecution in class ParallelExecutorBase<T>Exceptionprotected abstract void union()
throws Exception
Exceptionprotected String getExecutorType()
getExecutorType in class ParallelExecutorBase<T>Copyright © 2015-2021 Eclipse Foundation. All Rights Reserved.