public class SynchronousJoin extends JoinExecutorBase<BindingSet>
bindings, joinVars, leftIter, rightArgclosed, evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy| Constructor and Description |
|---|
SynchronousJoin(FederationEvalStrategy strategy,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
TupleExpr rightArg,
BindingSet bindings,
QueryInfo queryInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleBindings()
Implementations must implement this method to handle bindings.
|
getExecutorType, getJoinVars, handleClose, performExecution, setJoinVarsaddResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toStringhasNext, next, removeclose, isClosedpublic SynchronousJoin(FederationEvalStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, TupleExpr rightArg, BindingSet bindings, QueryInfo queryInfo) throws QueryEvaluationException
QueryEvaluationExceptionprotected void handleBindings()
throws Exception
JoinExecutorBase
while (!closed && leftIter.hasNext()) {
// your code
}
and add results to rightQueue. Note that addResult() is implemented synchronized and thus thread safe. In case
you can guarantee sequential access, it is also possible to directly access rightQueue
Note that the implementation must block until the entire join is executed.handleBindings in class JoinExecutorBase<BindingSet>ExceptionCopyright © 2015-2020 Eclipse Foundation. All Rights Reserved.