public class SynchronousWorkerUnion<T> extends WorkerUnionBase<T>
ParallelExecutorBase.run() methodtasksclosed, evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy| Constructor and Description |
|---|
SynchronousWorkerUnion(FederationEvalStrategy strategy,
QueryInfo queryInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
union()
Note: this method must block until the union is executed completely.
|
addTaskgetExecutorType, performExecutionaddResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, handleClose, isFinished, run, toss, toStringhasNext, next, removeclose, isClosedpublic SynchronousWorkerUnion(FederationEvalStrategy strategy, QueryInfo queryInfo)
protected void union()
throws Exception
UnionExecutorBaseunion in class UnionExecutorBase<T>ExceptionCopyright © 2015-2020 Eclipse Foundation. All Rights Reserved.